Mercurial > pub > ImplabNet
annotate Implab/FuncTask.cs @ 203:4d9830a9bbb8 v2
Added 'Fail' method to RunnableComponent which allows component to move from
Running to Failed state.
Added PollingComponent a timer based runnable component
More tests
Added FailPromise a thin class to wrap exceptions
Fixed error handling in SuccessPromise classes.
| author | cin |
|---|---|
| date | Tue, 18 Oct 2016 17:49:54 +0300 |
| parents | 40d7fed4a09e |
| children | eee3e49dd1ff |
| rev | line source |
|---|---|
| 144 | 1 using System; |
| 2 using System.Threading; | |
| 3 | |
| 4 namespace Implab { | |
| 5 public class FuncTask<T> : FuncTaskBase<T>, IDeferred { | |
| 6 readonly Func<T> m_task; | |
| 7 | |
| 149 | 8 public FuncTask(Func<T> task, Func<Exception, T> error, Func<Exception, T> cancel, bool autoCancellable) : base(error, cancel, autoCancellable) { |
| 144 | 9 m_task = task; |
| 10 } | |
| 11 | |
| 12 public void Resolve() { | |
| 13 if (m_task != null && LockCancelation()) { | |
| 14 try { | |
| 15 SetResult(m_task()); | |
| 16 } 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
|
17 SetErrorInternal(err); |
| 144 | 18 } |
| 19 } | |
| 20 } | |
| 21 } | |
| 22 } | |
| 23 |