FuncTaskBase.cs
52 lines
| 1.5 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / FuncTaskBase.cs
|
|
r144 | using System; | ||
| namespace Implab { | ||||
|
|
r187 | public class FuncTaskBase<TResult> : AbstractTask<TResult> { | ||
|
|
r144 | readonly Func<Exception, TResult> m_cancel; | ||
| readonly Func<Exception, TResult> m_error; | ||||
|
|
r149 | protected FuncTaskBase( Func<Exception, TResult> error, Func<Exception, TResult> cancel, bool autoCancellable) { | ||
|
|
r144 | m_error = error; | ||
| m_cancel = cancel; | ||||
|
|
r149 | if (autoCancellable) | ||
| CancellationRequested(CancelOperation); | ||||
|
|
r144 | } | ||
| public void Reject(Exception error) { | ||||
| Safe.ArgumentNotNull(error, "error"); | ||||
| if (LockCancelation()) | ||||
| HandleErrorInternal(error); | ||||
| } | ||||
| protected void HandleErrorInternal(Exception error) { | ||||
| if (m_error != null) { | ||||
| try { | ||||
| SetResult(m_error(error)); | ||||
| } catch(Exception err) { | ||||
|
|
r187 | SetErrorInternal(err); | ||
|
|
r144 | } | ||
| } else { | ||||
|
|
r187 | SetErrorInternal(error); | ||
|
|
r144 | } | ||
| } | ||||
| public override void CancelOperation(Exception reason) { | ||||
|
|
r187 | if (LockCancelation()) | ||
| HandleCancelInternal(reason); | ||||
| } | ||||
| protected void HandleCancelInternal(Exception reason) { | ||||
| if (m_cancel != null) { | ||||
| try { | ||||
| SetResult(m_cancel(reason)); | ||||
| } catch (Exception err) { | ||||
|
|
r196 | SetErrorInternal(err); | ||
|
|
r144 | } | ||
|
|
r187 | } else { | ||
|
|
r196 | SetCancelledInternal(reason); | ||
|
|
r144 | } | ||
| } | ||||
| } | ||||
| } | ||||
