AsyncComponent.ts
39 lines
| 1.2 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r13 | import { Cancellation } from "../Cancellation"; | |
|
cin
|
r22 | import { IAsyncComponent, ICancellation, ICancellable, IDestroyable } from "../interfaces"; | |
| import { destroy } from "../safe"; | |||
|
cin
|
r9 | ||
|
cin
|
r22 | export class AsyncComponent implements IAsyncComponent, ICancellable { | |
| _cancel: (e) => void; | |||
|
cin
|
r13 | _completion: Promise<void> = Promise.resolve(); | |
|
cin
|
r9 | ||
| getCompletion() { return this._completion }; | |||
|
cin
|
r13 | runOperation(op: (ct: ICancellation) => any, ct: ICancellation = Cancellation.none) { | |
|
cin
|
r22 | // create inner cancellation bound to the passed cancellation token | |
| let h: IDestroyable; | |||
| let inner = new Cancellation(cancel => { | |||
| this._cancel = cancel; | |||
| h = ct.register(cancel); | |||
| }); | |||
|
cin
|
r13 | // TODO create cancellation source here | |
|
cin
|
r22 | let guard = async () => { | |
| try { | |||
| await op(inner); | |||
| } finally { | |||
| // after the operation is complete we need to cleanup the | |||
| // resources | |||
| destroy(h); | |||
| this._cancel = null; | |||
| } | |||
|
cin
|
r13 | } | |
|
cin
|
r9 | ||
|
cin
|
r13 | return this._completion = guard(); | |
|
cin
|
r9 | } | |
|
cin
|
r22 | ||
| cancel(reason) { | |||
| if (this._cancel) | |||
| this._cancel(reason); | |||
| } | |||
|
cin
|
r9 | } |