Mercurial > pub > ImplabNet
view Implab/Deferred.cs @ 246:5aa9cfbe56c3 v3
missing files
author | cin |
---|---|
date | Fri, 26 Jan 2018 11:19:38 +0300 |
parents | b904e0a3ba72 |
children | 5cb4826c2c2a |
line wrap: on
line source
using System; using System.Diagnostics; namespace Implab { /// <summary> /// This class is responsible for the promise resolution, dispatching and chaining /// </summary> public class Deferred : IResolvable { readonly AbstractPromise m_promise; readonly IDispatcher m_dispatcher; internal Deferred(AbstractPromise promise, IDispatcher dispatcher) { Debug.Assert(promise != null); m_promise = promise; m_dispatcher = dispatcher; } public IPromise Promise { get { return m_promise; } } public void Reject(Exception error) { m_promise.Reject(error); } public void Resolve() { m_promise.Resolve(); } public void Resolve(IPromise 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 thenable) { try { thenable.Then(this); } catch (Exception err) { Reject(err); } } } }