PromiseExtensions.cs
226 lines
| 10.0 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / PromiseExtensions.cs
cin
|
r72 | using System.Threading; | ||
|
cin
|
r75 | using System; | ||
|
cin
|
r109 | using Implab.Diagnostics; | ||
|
cin
|
r119 | using System.Collections.Generic; | ||
|
cin
|
r248 | using System.Linq; | ||
|
cin
|
r72 | namespace Implab { | ||
| public static class PromiseExtensions { | ||||
|
cin
|
r248 | public static IPromise Then(this IPromise that, Action fulfilled, Action<Exception> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise Then(this IPromise that, Action fulfilled) { | ||||
| var reaction = PromiseActionReaction.Create(fulfilled, null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r101 | } | ||
|
cin
|
r248 | public static IPromise Then(this IPromise that, Action fulfilled, Func<Exception, IPromise> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r207 | } | ||
|
cin
|
r248 | public static IPromise Then(this IPromise that, Func<IPromise> fulfilled, Action<Exception> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise Then(this IPromise that, Func<IPromise> fulfilled) { | ||||
| var reaction = PromiseActionReaction.Create(fulfilled, null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r75 | } | ||
|
cin
|
r110 | |||
|
cin
|
r248 | public static IPromise Then(this IPromise that, Func<IPromise> fulfilled, Func<Exception, IPromise> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r110 | } | ||
|
cin
|
r119 | |||
|
cin
|
r248 | public static IPromise Then<T>(this IPromise<T> that, Action<T> fulfilled, Action<Exception> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction<T>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise Then<T>(this IPromise<T> that, Action<T> fulfilled) { | ||||
| var reaction = PromiseActionReaction<T>.Create(fulfilled, null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r205 | } | ||
|
cin
|
r248 | public static IPromise Then<T>(this IPromise<T> that, Action<T> fulfilled, Func<Exception, IPromise> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction<T>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r208 | } | ||
|
cin
|
r248 | public static IPromise Then<T>(this IPromise<T> that, Func<T, IPromise> fulfilled, Action<Exception> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction<T>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise Then<T>(this IPromise<T> that, Func<T, IPromise> fulfilled) { | ||||
| var reaction = PromiseActionReaction<T>.Create(fulfilled, null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r124 | } | ||
|
cin
|
r145 | |||
|
cin
|
r248 | public static IPromise Then<T>(this IPromise<T> that, Func<T, IPromise> fulfilled, Func<Exception, IPromise> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseActionReaction<T>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
| } | ||||
|
cin
|
r145 | |||
|
cin
|
r248 | public static IPromise<Tout> Then<Tout>(this IPromise that, Func<Tout> fulfilled, Func<Exception, Tout> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise<Tout> Then<Tout>(this IPromise that, Func<Tout> fulfilled) { | ||||
| var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, (Func<Exception, Tout>)null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tout>(this IPromise that, Func<Tout> fulfilled, Func<Exception, IPromise<Tout>> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tout>(this IPromise that, Func<IPromise<Tout>> fulfilled, Func<Exception, Tout> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise<Tout> Then<Tout>(this IPromise that, Func<IPromise<Tout>> fulfilled) { | ||||
| var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, (Func<Exception, Tout>)null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r207 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tout>(this IPromise that, Func<IPromise<Tout>> fulfilled, Func<Exception, IPromise<Tout>> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, Tout> fulfilled, Func<Exception, Tout> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, Tout> fulfilled) { | ||||
| var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, (Func<Exception, Tout>)null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r207 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, Tout> fulfilled, Func<Exception, IPromise<Tout>> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r207 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, IPromise<Tout>> fulfilled, Func<Exception, Tout> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
| that.Then(reaction); | ||||
| return reaction.Promise; | ||||
| } | ||||
| public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, IPromise<Tout>> fulfilled) { | ||||
| var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, (Func<Exception, Tout>)null, Promise.DefaultDispatcher); | ||||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r207 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Then<Tin, Tout>(this IPromise<Tin> that, Func<Tin, IPromise<Tout>> fulfilled, Func<Exception, IPromise<Tout>> rejected) { | ||
|
cin
|
r249 | var reaction = PromiseFuncReaction<Tin, Tout>.Create(fulfilled, rejected, Promise.DefaultDispatcher); | ||
|
cin
|
r248 | that.Then(reaction); | ||
| return reaction.Promise; | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise Catch(this IPromise that, Action<Exception> rejected) { | ||
| return Then(that, null, rejected); | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise Catch(this IPromise that, Func<Exception, IPromise> rejected) { | ||
| return Then(that, null, rejected); | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Catch<Tout>(this IPromise that, Func<Exception, Tout> rejected) { | ||
| return Then(that, (Func<Tout>)null, rejected); | ||||
|
cin
|
r145 | } | ||
|
cin
|
r248 | public static IPromise<Tout> Catch<Tout>(this IPromise that, Func<Exception, IPromise<Tout>> rejected) { | ||
| return Then(that, (Func<Tout>)null, rejected); | ||||
| } | ||||
|
cin
|
r75 | |||
|
cin
|
r248 | public static IPromise<Tout> Catch<Tin, Tout>(this IPromise<Tin> that, Func<Exception, Tout> rejected) { | ||
| return Then(that, (Func<Tin, Tout>)null, rejected); | ||||
| } | ||||
|
cin
|
r208 | |||
|
cin
|
r248 | public static IPromise<Tout> Catch<Tin, Tout>(this IPromise<Tin> that, Func<Exception, IPromise<Tout>> rejected) { | ||
| return Then(that, (Func<Tin, Tout>)null, rejected); | ||||
| } | ||||
|
cin
|
r249 | |||
| public static IPromise Finally(this IPromise that, Action final) { | ||||
| return Then(that, final, e => { | ||||
| final(); | ||||
| throw e.Rethrow(); | ||||
| }); | ||||
| } | ||||
| public static IPromise Finally(this IPromise that, Func<IPromise> final) { | ||||
| return Then(that, final, e => { | ||||
| final(); | ||||
| throw e.Rethrow(); | ||||
| }); | ||||
| } | ||||
| public static IPromise<T> Finally<T>(this IPromise<T> that, Action final) { | ||||
| return Then<T, T>(that, x => { | ||||
| final(); | ||||
| return x; | ||||
| }, new Func<Exception, T>(e => { | ||||
| final(); | ||||
| throw e.Rethrow(); | ||||
| })); | ||||
| } | ||||
| public static IPromise<T> Finally<T>(this IPromise<T> that, Func<IPromise> final) { | ||||
| return Then<T, T>(that, x => { | ||||
| return final() | ||||
| .Then(() => x); | ||||
| }, new Func<Exception, IPromise<T>>(e => { | ||||
| return final() | ||||
| .Then(new Func<T>(() => { | ||||
| throw e.Rethrow(); | ||||
| })); | ||||
| })); | ||||
| } | ||||
|
cin
|
r259 | public static PromiseAwaiter GetAwaiter(this IPromise that) { | ||
| Safe.ArgumentNotNull(that, nameof(that)); | ||||
| return new PromiseAwaiter(that); | ||||
| } | ||||
| public static PromiseAwaiter<T> GetAwaiter<T>(this IPromise<T> that) { | ||||
| Safe.ArgumentNotNull(that, nameof(that)); | ||||
| return new PromiseAwaiter<T>(that); | ||||
| } | ||||
|
cin
|
r249 | |||
|
cin
|
r72 | } | ||
| } | ||||