AsyncComponent.ts
38 lines
| 1.2 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r49 | import { Cancellation } from "../Cancellation"; | ||
|
cin
|
r170 | import { IAsyncComponent, ICancellation, ICancellable } from "../interfaces"; | ||
|
cin
|
r49 | |||
|
cin
|
r134 | const noop = () => void (0); | ||
|
cin
|
r49 | export class AsyncComponent implements IAsyncComponent, ICancellable { | ||
|
cin
|
r134 | _cancel: ((e: any) => void) = noop; | ||
|
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 | ||||
|
cin
|
r54 | const inner = new Cancellation(cancel => { | ||
|
cin
|
r49 | this._cancel = cancel; | ||
| }); | ||||
|
cin
|
r54 | const guard = async () => { | ||
|
cin
|
r49 | try { | ||
|
cin
|
r172 | const combined = Cancellation.combine(ct, inner); | ||
| const result = await op(combined); | ||||
| combined.throwIfRequested(); | ||||
| return result; | ||||
|
cin
|
r49 | } finally { | ||
| // after the operation is complete we need to cleanup the | ||||
| // resources | ||||
|
cin
|
r134 | this._cancel = noop; | ||
|
cin
|
r49 | } | ||
|
cin
|
r54 | }; | ||
|
cin
|
r49 | |||
| return this._completion = guard(); | ||||
| } | ||||
|
cin
|
r59 | cancel(reason: any) { | ||
|
cin
|
r134 | this._cancel(reason); | ||
|
cin
|
r49 | } | ||
|
cin
|
r54 | } | ||