##// END OF EJS Templates
implab » ImplabNet
RSS
ServiceLocator: added a cleanup callback to the service registration method
ServiceLocator: added a cleanup callback to the service registration method
cin - - Load All Authors

File last commit:

r76:c761fc982e1d v2
r86:b33832ab0262 v2
Show More
PromiseExtensions.cs
65 lines | 1.8 KiB | text/x-csharp | CSharpLexer
/ Implab / PromiseExtensions.cs
History | Annotation | Raw |Copy content |Copy permalink
using System.Threading;
using System;
#if NET_4_5
using System.Threading.Tasks;
#endif
namespace Implab {
public static class PromiseExtensions {
public static IPromise<T> DispatchToCurrentContext<T>(this IPromise<T> that) {
Safe.ArgumentNotNull(that, "that");
var context = SynchronizationContext.Current;
if (context == null)
return that;
var p = new SyncContextPromise<T>(context, that, true);
that.Last(
p.Resolve,
p.Reject,
p.Cancel
);
return p;
}
public static IPromise<T> DispatchToContext<T>(this IPromise<T> that, SynchronizationContext context) {
Safe.ArgumentNotNull(that, "that");
Safe.ArgumentNotNull(context, "context");
var p = new SyncContextPromise<T>(context, that, true);
that.Last(
p.Resolve,
p.Reject,
p.Cancel
);
return p;
}
public static AsyncCallback AsyncCallback<T>(this Promise<T> that, Func<IAsyncResult,T> callback) {
Safe.ArgumentNotNull(that, "that");
Safe.ArgumentNotNull(callback, "callback");
return ar => {
try {
that.Resolve(callback(ar));
} catch (Exception err) {
that.Reject(err);
}
};
}
#if NET_4_5
public static Task<T> GetTask<T>(this IPromise<T> that) {
Safe.ArgumentNotNull(that, "that");
var tcs = new TaskCompletionSource<T>();
that.Last(tcs.SetResult, tcs.SetException, tcs.SetCanceled);
return tcs.Task;
}
#endif
}
}