Mercurial > pub > ImplabNet
annotate Implab/ActionChainTaskT.cs @ 210:5dc21f6a3222 v2
Code review for RunnableComponent
Added StaApartment class based on System.Windows.Forms.Application message loop
author | cin |
---|---|
date | Mon, 20 Mar 2017 17:44:18 +0300 |
parents | 40d7fed4a09e |
children |
rev | line source |
---|---|
145 | 1 using System; |
2 | |
3 namespace Implab { | |
4 public class ActionChainTask<T> : ActionChainTaskBase, IDeferred<T> { | |
5 readonly Func<T, IPromise> m_task; | |
6 | |
149 | 7 public ActionChainTask(Func<T, IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) : base(error,cancel, autoCancellable) { |
145 | 8 m_task = task; |
9 } | |
10 | |
11 public void Resolve(T value) { | |
12 if (m_task != null && LockCancelation()) { | |
13 try { | |
149 | 14 var p = m_task(value); |
187
dd4a3590f9c6
Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler
cin
parents:
149
diff
changeset
|
15 p.On(SetResult, HandleErrorInternal, HandleCancelInternal); |
149 | 16 CancellationRequested(p.Cancel); |
145 | 17 } catch(Exception err) { |
196
40d7fed4a09e
fixed promise chaining behavior, the error handler doesn't handle result or cancellation handlers exceptions these exceptions are propagated to the next handlers.
cin
parents:
187
diff
changeset
|
18 SetErrorInternal(err); |
145 | 19 } |
20 } | |
21 } | |
22 | |
23 } | |
24 } | |
25 |