diff Implab/PromiseAwaiter`1.cs @ 248:5cb4826c2c2a v3

Added awaiters to promises Added static methods to Promise Resolve, Reject, All. Updated promise helpers
author cin
date Tue, 30 Jan 2018 01:37:17 +0300
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Implab/PromiseAwaiter`1.cs	Tue Jan 30 01:37:17 2018 +0300
@@ -0,0 +1,62 @@
+using System;
+using System.Runtime.CompilerServices;
+using System.Threading;
+using Implab.Parallels;
+
+namespace Implab {
+    public struct PromiseAwaiter<T> : INotifyCompletion {
+        class PromiseEvent : IResolvable<T> {
+            IDispatcher m_dispatcher;
+
+            Action m_handler;
+
+            public PromiseEvent(Action handler, IDispatcher dispatcher) {
+                m_handler = handler;
+                m_dispatcher = dispatcher;
+            }
+
+            public void Resolve(T result) {
+                m_dispatcher.Enqueue(m_handler);
+            }
+
+            public void Reject(Exception error) {
+                m_dispatcher.Enqueue(m_handler);
+            }
+        }
+
+        readonly IPromise<T> m_promise;
+
+        readonly IDispatcher m_dispatcher;
+
+        public PromiseAwaiter(IPromise<T> promise) {
+            m_promise = promise;
+            m_dispatcher = GetDispatcher();
+        }
+
+        public PromiseAwaiter(IPromise<T> promise, IDispatcher dispatcher) {
+            m_promise = promise;
+            m_dispatcher = dispatcher;
+        }
+
+        public void OnCompleted(Action continuation) {
+            if (m_promise != null)
+                m_promise.Then(new PromiseEvent(continuation, GetDispatcher()));
+        }
+
+        public T GetResult() {
+            return m_promise.Join();
+        }
+
+        static IDispatcher GetDispatcher() {
+            if (SynchronizationContext.Current == null)
+                return ThreadPoolDispatcher.Instance;
+            return new SyncContextDispatcher(SynchronizationContext.Current);
+        }
+
+        public bool IsCompleted {
+            get {
+                return m_promise.IsResolved;
+            }
+        }
+    }
+}
\ No newline at end of file