AsyncComponent.ts
16 lines
| 531 B
| video/mp2t
|
TypeScriptLexer
cin
|
r13 | import { Cancellation } from "../Cancellation"; | |
| import { IAsyncComponent, ICancellation } from "../interfaces"; | |||
|
cin
|
r9 | ||
|
cin
|
r13 | export class AsyncComponent implements IAsyncComponent { | |
| _completion: Promise<void> = Promise.resolve(); | |||
|
cin
|
r9 | ||
| getCompletion() { return this._completion }; | |||
|
cin
|
r13 | runOperation(op: (ct: ICancellation) => any, ct: ICancellation = Cancellation.none) { | |
| // TODO create cancellation source here | |||
| async function guard() { | |||
| await op(ct); | |||
| } | |||
|
cin
|
r9 | ||
|
cin
|
r13 | return this._completion = guard(); | |
|
cin
|
r9 | } | |
| } |