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