Cancellation.ts
66 lines
| 1.4 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r13 | import { ICancellation } from "./interfaces"; | |
|
cin
|
r17 | import { argumentNotNull } from "./safe"; | |
|
cin
|
r13 | ||
| export class Cancellation implements ICancellation { | |||
|
cin
|
r17 | private _reason: any; | |
| private _cbs: Array<(e) => void>; | |||
| constructor(action: (cancel: (e) => void) => void) { | |||
| argumentNotNull(action, "action"); | |||
| action(this._cancel.bind(this)); | |||
| } | |||
|
cin
|
r13 | isSupported(): boolean { | |
|
cin
|
r17 | return true; | |
|
cin
|
r13 | } | |
| throwIfRequested(): void { | |||
|
cin
|
r17 | if (this._reason) | |
| throw this._reason; | |||
|
cin
|
r13 | } | |
|
cin
|
r17 | ||
|
cin
|
r13 | isRequested(): boolean { | |
|
cin
|
r17 | return !!this._reason; | |
|
cin
|
r13 | } | |
|
cin
|
r17 | register(cb: (e: any) => void): void { | |
| argumentNotNull(cb, "cb"); | |||
| if (this._reason) { | |||
| cb(this._reason); | |||
| } else { | |||
| if (!this._cbs) | |||
| this._cbs = [cb]; | |||
| else | |||
| this._cbs.push(cb); | |||
| } | |||
|
cin
|
r13 | } | |
|
cin
|
r17 | private _cancel(reason) { | |
| if (this._reason) | |||
| return; | |||
| this._reason = (reason = reason || new Error("Operation cancelled")); | |||
| if (this._cbs) { | |||
| this._cbs.forEach(cb => cb(reason)); | |||
| this._cbs = null; | |||
| } | |||
| } | |||
| static readonly none: ICancellation = { | |||
|
cin
|
r13 | isSupported(): boolean { | |
| return false; | |||
| }, | |||
| throwIfRequested(): void { | |||
| }, | |||
|
cin
|
r17 | ||
|
cin
|
r13 | isRequested(): boolean { | |
| return false; | |||
| }, | |||
|
cin
|
r17 | ||
| register(_cb: (e: any) => void): void { | |||
|
cin
|
r13 | } | |
| }; | |||
| } |