view Implab/SyncContextPromise.cs @ 121:62d2f1e98c4e v2

working version of AsyncQueue and batch operations tests
author cin
date Mon, 12 Jan 2015 18:19:41 +0300
parents 2573b562e328
children f75cfa58e3d4
line wrap: on
line source

using System.Threading;

namespace Implab {
    public class SyncContextPromise<T> : Promise<T> {
        readonly SynchronizationContext m_context;

        public SyncContextPromise(SynchronizationContext context) {
            Safe.ArgumentNotNull(context, "context");
            m_context = context;
        }

        protected override void SignalSuccess(IDeferred<T> handler) {
            m_context.Post(x => base.SignalSuccess(handler), null);
        }

        protected override void SignalError(IDeferred<T> handler, System.Exception error) {
            m_context.Post(x => base.SignalError(handler, error), null);
        }

        protected override void SignalCancelled(IDeferred<T> handler) {
            m_context.Post(x => base.SignalCancelled(handler), null);
        }
    }
}