##// END OF EJS Templates
implab » ImplabNet
RSS
Implab.Test moved to xunit...
Implab.Test moved to xunit Complete set of PromiseHelpers (Then, Catch, Finally) Removed obsolete types ICancellable, ICancellationToken
cin - - Load All Authors

File last commit:

r249:d82909310094 v3
r249:d82909310094 v3
Show More
PromiseHandler.cs
101 lines | 2.8 KiB | text/x-csharp | CSharpLexer
/ Implab / PromiseHandler.cs
History | Annotation | Raw |Copy content |Copy permalink
using System;
using System.Diagnostics;
namespace Implab {
class PromiseHandler {
public static Action<T, Deferred> Create<T>(Action<T> handler) {
Debug.Assert(handler != null);
return (v, next) => {
try {
handler(v);
next.Resolve();
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<T, Deferred> Create<T>(Func<T, IPromise> handler) {
Debug.Assert(handler != null);
return (v, next) => {
try {
next.Resolve(handler(v));
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<T, Deferred<T2>> Create<T, T2>(Func<T, T2> handler) {
Debug.Assert(handler != null);
return (v, next) => {
try {
next.Resolve(handler(v));
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<T, Deferred<T2>> Create<T, T2>(Func<T, IPromise<T2>> handler) {
Debug.Assert(handler != null);
return (v, next) => {
try {
next.Resolve(handler(v));
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<Deferred> Create(Action handler) {
Debug.Assert(handler != null);
return (next) => {
try {
handler();
next.Resolve();
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<Deferred> Create(Func<IPromise> handler) {
Debug.Assert(handler != null);
return (next) => {
try {
next.Resolve(handler());
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<Deferred<T2>> Create<T2>(Func<T2> handler) {
Debug.Assert(handler != null);
return (next) => {
try {
next.Resolve(handler());
} catch (Exception err) {
next.Reject(err);
}
};
}
public static Action<Deferred<T2>> Create<T2>(Func<IPromise<T2>> handler) {
Debug.Assert(handler != null);
return (next) => {
try {
next.Resolve(handler());
} catch (Exception err) {
next.Reject(err);
}
};
}
}
}