pub/ImplabNet: Implab/PromiseAll.cs comparison

Added awaiters to promises Added static methods to Promise Resolve, Reject, All. Updated promise helpers

comparison

equal deleted inserted replaced

-:fb70574741a1
+:5cb4826c2c2a
+using System;
+using System.Threading;
+namespace Implab
+{
+class PromiseAll : IResolvable {
+int m_count;
+readonly Deferred m_deferred;
+public bool Done {
+get { return m_deferred.Promise.IsResolved; }
+}
+public IPromise ResultPromise {
+get { return m_deferred.Promise; }
+}
+public void AddPromise(IPromise promise) {
+Interlocked.Increment(ref m_count);
+}
+public PromiseAll(Deferred deferred) {
+m_deferred = deferred;
+}
+public void Resolve() {
+if (Interlocked.Decrement(ref m_count) == 0)
+m_deferred.Resolve();
+}
+public void Complete() {
+Resolve();
+}
+public void Reject(Exception error) {
+m_deferred.Reject(error);
+}
+}
+}

Mercurial > pub > ImplabNet