Mercurial > pub > ImplabNet
diff Implab/Deferred`1.cs @ 249:d82909310094 v3
Implab.Test moved to xunit
Complete set of PromiseHelpers (Then, Catch, Finally)
Removed obsolete types ICancellable, ICancellationToken
author | cin |
---|---|
date | Wed, 31 Jan 2018 11:28:38 +0300 |
parents | 5cb4826c2c2a |
children | 7c7e9ad6fe4a |
line wrap: on
line diff
--- a/Implab/Deferred`1.cs Tue Jan 30 01:37:17 2018 +0300 +++ b/Implab/Deferred`1.cs Wed Jan 31 11:28:38 2018 +0300 @@ -4,46 +4,41 @@ namespace Implab { public class Deferred<T> : IResolvable<T> { readonly Promise<T> m_promise; - readonly IDispatcher m_dispatcher; - internal Deferred(IDispatcher dispatcher) : this(new Promise<T>(), dispatcher) { + internal Deferred() { + m_promise = new Promise<T>(); } - internal Deferred(Promise<T> promise, IDispatcher dispatcher) { + protected Deferred(Promise<T> promise) { Debug.Assert(promise != null); m_promise = promise; - m_dispatcher = dispatcher; } public IPromise<T> Promise { get { return m_promise; } } - public void Reject(Exception error) { + public void Cancel() { + Reject(new OperationCanceledException()); + } + + public virtual void Reject(Exception error) { if (error is PromiseTransientException) error = ((PromiseTransientException)error).InnerException; m_promise.RejectPromise(error); } - public void Resolve(T value) { + public virtual void Resolve(T value) { m_promise.ResolvePromise(value); } - public void Resolve(IPromise<T> thenable) { + public virtual void Resolve(IPromise<T> thenable) { if (thenable == null) Reject(new Exception("The promise or task are expected")); if (thenable == m_promise) Reject(new Exception("The promise cannot be resolved with oneself")); - else if (m_dispatcher != null) - // dispatch (see ecma-262/6.0: 25.4.1.3.2 Promise Resolve Functions) - m_dispatcher.Enqueue(Chain, thenable); - else - Chain(thenable); - } - - void Chain(IPromise<T> thenable) { try { thenable.Then(this); } catch (Exception err) {