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");
                         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,
                             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