implab/ImplabNet Files · Implab/PromiseFuncReaction`2.cs

Added awaiters to promises...

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

cin - - Load All Authors

File last commit:

r248:5cb4826c2c2a v3


                r248:5cb4826c2c2a

Download file

             PromiseFuncReaction`2.cs
        
                    55 lines
            
             | 2.2 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / PromiseFuncReaction`2.cs
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
Added awaiters to promises...

              r248
            
      using System;

      using System.Diagnostics;

      namespace Implab {

          class PromiseFuncReaction<TIn, TRet> : PromiseReaction<TIn> {

              readonly Deferred<TRet> m_next;

              public IPromise<TRet> Promise { 

                  get { return m_next.Promise; }

              }

              public PromiseFuncReaction(Func<TIn, TRet> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) : base(dispatcher) {

                  m_next = new Deferred<TRet>(dispatcher);

                  if (fulfilled != null)

                      FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

                  if (rejected != null)

                      RejectHandler = PromiseHandler.Create(rejected, m_next);

              }

              public PromiseFuncReaction(Func<TIn, IPromise<TRet>> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) : base(dispatcher) {

                  m_next = new Deferred<TRet>(dispatcher);

                  if (fulfilled != null)

                      FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

                  if (rejected != null)

                      RejectHandler = PromiseHandler.Create(rejected, m_next);

              }

              public PromiseFuncReaction(Func<TIn, TRet> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) : base(dispatcher) {

                  m_next = new Deferred<TRet>(dispatcher);

                  if (fulfilled != null)

                      FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

                  if (rejected != null)

                      RejectHandler = PromiseHandler.Create(rejected, m_next);

              }

              public PromiseFuncReaction(Func<TIn, IPromise<TRet>> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) : base(dispatcher) {

                  m_next = new Deferred<TRet>(dispatcher);

                  if (fulfilled != null)

                      FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

                  if (rejected != null)

                      RejectHandler = PromiseHandler.Create(rejected, m_next);

              }

              protected override void DefaultReject(Exception reason) {

                  m_next.Reject(reason);

              }

              protected override void DefaultResolve(TIn result) {

                  m_next.Resolve((TRet)(object)result);

              }

          }

      }

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

cin Added awaiters to promises...	r248	using System;
		using System.Diagnostics;

		namespace Implab {
		class PromiseFuncReaction<TIn, TRet> : PromiseReaction<TIn> {
		readonly Deferred<TRet> m_next;

		public IPromise<TRet> Promise {
		get { return m_next.Promise; }
		}

		public PromiseFuncReaction(Func<TIn, TRet> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) : base(dispatcher) {
		m_next = new Deferred<TRet>(dispatcher);
		if (fulfilled != null)
		FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

		if (rejected != null)
		RejectHandler = PromiseHandler.Create(rejected, m_next);
		}

		public PromiseFuncReaction(Func<TIn, IPromise<TRet>> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) : base(dispatcher) {
		m_next = new Deferred<TRet>(dispatcher);
		if (fulfilled != null)
		FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

		if (rejected != null)
		RejectHandler = PromiseHandler.Create(rejected, m_next);
		}

		public PromiseFuncReaction(Func<TIn, TRet> fulfilled, Func<Exception, IPromise<TRet>> rejected, IDispatcher dispatcher) : base(dispatcher) {
		m_next = new Deferred<TRet>(dispatcher);
		if (fulfilled != null)
		FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

		if (rejected != null)
		RejectHandler = PromiseHandler.Create(rejected, m_next);
		}

		public PromiseFuncReaction(Func<TIn, IPromise<TRet>> fulfilled, Func<Exception, TRet> rejected, IDispatcher dispatcher) : base(dispatcher) {
		m_next = new Deferred<TRet>(dispatcher);
		if (fulfilled != null)
		FulfilHandler = PromiseHandler.Create(fulfilled, m_next);

		if (rejected != null)
		RejectHandler = PromiseHandler.Create(rejected, m_next);
		}

		protected override void DefaultReject(Exception reason) {
		m_next.Reject(reason);
		}

		protected override void DefaultResolve(TIn result) {
		m_next.Resolve((TRet)(object)result);
		}
		}
		}