view Implab/PromiseAll.cs @ 260:547a2fc0d93e v3 v3.0.6

minor fixes
author cin
date Fri, 13 Apr 2018 19:14:59 +0300
parents 5cb4826c2c2a
children
line wrap: on
line source

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);
        }
    }
}