Deferred`1.cs
60 lines
| 1.7 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / Deferred`1.cs
cin
|
r246 | using System; | |
| using System.Diagnostics; | |||
|
cin
|
r251 | using System.Threading.Tasks; | |
|
cin
|
r246 | ||
| namespace Implab { | |||
| public class Deferred<T> : IResolvable<T> { | |||
|
cin
|
r248 | readonly Promise<T> m_promise; | |
|
cin
|
r246 | ||
|
cin
|
r249 | internal Deferred() { | |
| m_promise = new Promise<T>(); | |||
|
cin
|
r248 | } | |
|
cin
|
r249 | protected Deferred(Promise<T> promise) { | |
|
cin
|
r246 | Debug.Assert(promise != null); | |
| m_promise = promise; | |||
| } | |||
| public IPromise<T> Promise { | |||
| get { return m_promise; } | |||
| } | |||
|
cin
|
r249 | public void Cancel() { | |
| Reject(new OperationCanceledException()); | |||
| } | |||
| public virtual void Reject(Exception error) { | |||
|
cin
|
r248 | if (error is PromiseTransientException) | |
| error = ((PromiseTransientException)error).InnerException; | |||
| m_promise.RejectPromise(error); | |||
|
cin
|
r246 | } | |
|
cin
|
r249 | public virtual void Resolve(T value) { | |
|
cin
|
r248 | m_promise.ResolvePromise(value); | |
|
cin
|
r246 | } | |
|
cin
|
r249 | public virtual void Resolve(IPromise<T> thenable) { | |
|
cin
|
r246 | 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")); | |||
| try { | |||
| thenable.Then(this); | |||
| } catch (Exception err) { | |||
| Reject(err); | |||
| } | |||
| } | |||
|
cin
|
r251 | ||
| public virtual void Resolve(Task<T> thenable) { | |||
| if (thenable == null) | |||
| Reject(new Exception("The promise or task are expected")); | |||
| try { | |||
| thenable.Then(this); | |||
| } catch (Exception err) { | |||
| Reject(err); | |||
| } | |||
| } | |||
|
cin
|
r246 | } | |
| } |