Mercurial > pub > ImplabNet
annotate Implab/ActionChainTaskT.cs @ 212:a01d9df88d74 v2
Added class Trace<T> to manage channels for individual classes, if SomeClass
uses Trace<SomeClass> it sould be marked with TraceSourceAttribute
| author | cin |
|---|---|
| date | Tue, 04 Apr 2017 12:04:05 +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 |