implab/ImplabNet Commit - r209:a867536c68fc

Bound promise to CancellationToken...

cin -

r209:a867536c68fc v2

parent child

Context file:

r209:a867536c68fc

Collapse all files

Implab/Components/ExecutionState.cs +6 0

                      Running,
+                     Suspending,
+                     Suspended,
+                     Resuming,
                      Stopping,
                      Failed,

Implab/PromiseExtensions.cs +31 -4

                      /// <param name="cleanup">A callback used to cleanup already resolved promises in case of an error</param>
                      /// <returns></returns>
                      public static IPromise<T[]> PromiseAll<T>(this ICollection<IPromise<T>> that, Action<T> cleanup) {
-                         Safe.ArgumentNotNull(that, "that");
+                         Safe.ArgumentNotNull(that, "that");
                          int count = that.Count;
                          if (count == 0)
                      public static IPromise<T2> Then<T, T2>(this IPromise<T> that, Func<T, T2> success, Func<Exception, T2> error, Func<Exception, T2> cancel) {
                          Safe.ArgumentNotNull(that, "that");
+                         Safe.ArgumentNotNull(success, "success");
                          var d = new FuncTask<T, T2>(success, error, cancel, false);
                          that.On(d.Resolve, d.Reject, d.CancelOperation);
                          d.CancellationRequested(that.Cancel);
                                  success(x);
                                  return x;
                              },
-                             error,
-                             cancel,
+                             error,
+                             cancel,
                              false
                          );
                          that.On(d.Resolve, d.Reject, d.CancelOperation);
                      #endregion
+                     public static IPromise<T2> Guard<T, T2>(this IPromise<T> that, Func<IPromise<T>, IPromise<T2>> continuation, Action<T> cleanup) {
+                         Safe.ArgumentNotNull(that, "that");
+                         Safe.ArgumentNotNull(continuation, "continuation");
+                         return continuation(that).Error((err) => {
+                             that.On(cleanup);
+                         }, true);
+                     }
              #if NET_4_5
                          return new PromiseAwaiter(that);
                      }
+                     public static IPromise BoundCancellationToken(this IPromise that, CancellationToken ct) {
+                         Safe.ArgumentNotNull(that, "that");
+                         ct.Register(that.Cancel);
+                         return that.Then(null, null, (err) => {
+                             ct.ThrowIfCancellationRequested();
+                             throw new PromiseTransientException(err);
+                         });
+                     }
+                     public static IPromise<T> BoundCancellationToken<T>(this IPromise<T> that, CancellationToken ct) {
+                         Safe.ArgumentNotNull(that, "that");
+                         ct.Register(that.Cancel);
+                         return that.Then(null, null, (err) => {
+                             ct.ThrowIfCancellationRequested();
+                             throw new PromiseTransientException(err);
+                         });
+                     }
              #endif
                  }
              }

Implab/Safe.cs +1 0

                              return Promise<T>.FromException(err);
                          }
                      }
                  }
              }

General Comments 3

sergey

|

Auto status change to "Under Review"

sergey

|

ok, latest stable version should be in default

Write
Preview

You need to be logged in to leave comments. Login now

	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