pub/ImplabNet: Implab/Promise.cs comparison

comparison Implab/Promise.cs @ 96:daffa72a1cec v2

Added the chaining method to the non-generic IPromise

author	cin
date	Thu, 30 Oct 2014 10:06:16 +0300
parents	4f20870d0816
children	8ddf1648eca4

comparison

equal deleted inserted replaced

-:0141a165d032
+:daffa72a1cec
 /// <typeparam name="TNew">Новый тип результата.</typeparam>
 /// <param name="mapper">Преобразование результата к новому типу.</param>
 /// <param name="error">Обработчик ошибки. Данный обработчик получит
 /// исключение возникшее при выполнении операции.</param>
 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
+/// <param name = "cancel"></param>
 public IPromise<TNew> Then<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<TNew> error, Action cancel) {
 Safe.ArgumentNotNull(mapper, "mapper");
 // создаем прицепленное обещание
 var medium = new Promise<TNew>(this, true);
 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
 /// <param name="error">Обработчик ошибки. Данный обработчик получит
 /// исключение возникшее при выполнении текуещй операции.</param>
 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
+/// <param name = "cancel"></param>
 public IPromise<TNew> Chain<TNew>(ResultMapper<T, IPromise<TNew>> chained, ErrorHandler<IPromise<TNew>> error, Action cancel) {
 Safe.ArgumentNotNull(chained, "chained");
 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
 #region IPromiseBase explicit implementation
 IPromise IPromise.Then(Action success, ErrorHandler error, Action cancel) {
 return Then(
-x => success(),
+success != null ? new ResultHandler<T>(x => success()) : null,
-e => {
+error != null ? new ErrorHandler<T>(e => {
 error(e);
 return default(T);
-},
+}) : null,
 cancel
 );
 }
 IPromise IPromise.Then(Action success, ErrorHandler error) {
 return Then(
-x => success(),
+success != null ? new ResultHandler<T>(x => success()) : null,
-e => {
+error != null ? new ErrorHandler<T>(e => {
 error(e);
 return default(T);
-}
+}) : null
 );
 }
 IPromise IPromise.Then(Action success) {
+Safe.ArgumentNotNull(success, "success");
 return Then(x => success());
 }
+IPromise IPromise.Chain(Func<IPromise> chained, ErrorHandler<IPromise> error, Action cancel) {
+return ChainNoResult(chained, error, cancel);
+}
+IPromise ChainNoResult(Func<IPromise> chained, ErrorHandler<IPromise> error, Action cancel) {
+Safe.ArgumentNotNull(chained, "chained");
+var medium = new Promise<object>(this, true);
+ResultHandler<T> resultHandler = delegate(T result) {
+if (medium.IsCancelled)
+return;
+var promise = chained();
+promise.Last(
+medium.Resolve,
+medium.Reject,
+() => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
+);
+// notify chained operation that it's not needed anymore
+// порядок вызова Then, Cancelled важен, поскольку от этого
+// зависит IsExclusive
+medium.Cancelled(() => {
+if (promise.IsExclusive)
+promise.Cancel();
+});
+};
+ErrorHandler<T> errorHandler;
+if (error != null)
+errorHandler = delegate(Exception e) {
+try {
+var promise = error(e);
+promise.Last(
+medium.Resolve,
+medium.Reject,
+() => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
+);
+// notify chained operation that it's not needed anymore
+// порядок вызова Then, Cancelled важен, поскольку от этого
+// зависит IsExclusive
+medium.Cancelled(() => {
+if (promise.IsExclusive)
+promise.Cancel();
+});
+} catch (Exception e2) {
+medium.Reject(e2);
+}
+return default(T);
+};
+else
+errorHandler = err => {
+medium.Reject(err);
+return default(T);
+};
+Action cancelHandler;
+if (cancel != null)
+cancelHandler = () => {
+if (cancel != null)
+cancel();
+medium.Cancel();
+};
+else
+cancelHandler = medium.Cancel;
+AddHandler(
+resultHandler,
+errorHandler,
+cancelHandler,
+null
+);
+return medium;
+}
+IPromise IPromise.Chain(Func<IPromise> chained, ErrorHandler<IPromise> error) {
+return ChainNoResult(chained, error, null);
+}
+IPromise IPromise.Chain(Func<IPromise> chained) {
+return ChainNoResult(chained, null, null);
+}
 void IPromise.Last(Action success, ErrorHandler error, Action cancel) {
 Last(x => success(), error, cancel);
 }

Mercurial > pub > ImplabNet

comparison Implab/Promise.cs @ 96:daffa72a1cec v2