Cancellation.ts
88 lines
| 1.9 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r18 | import { ICancellation, IDestroyable } from "./interfaces"; | ||
|
cin
|
r17 | import { argumentNotNull } from "./safe"; | ||
|
cin
|
r13 | |||
|
cin
|
r18 | const destroyed = { | ||
| destroy() { | ||||
| } | ||||
| }; | ||||
|
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
|
r18 | register(cb: (e: any) => void): IDestroyable { | ||
|
cin
|
r17 | argumentNotNull(cb, "cb"); | ||
| if (this._reason) { | ||||
| cb(this._reason); | ||||
|
cin
|
r18 | return destroyed; | ||
|
cin
|
r17 | } else { | ||
| if (!this._cbs) | ||||
| this._cbs = [cb]; | ||||
| else | ||||
| this._cbs.push(cb); | ||||
|
cin
|
r18 | |||
|
cin
|
r39 | const me = this; | ||
|
cin
|
r18 | return { | ||
|
cin
|
r39 | destroy() { | ||
| me._unregister(cb); | ||||
| } | ||||
|
cin
|
r18 | }; | ||
|
cin
|
r17 | } | ||
|
cin
|
r13 | } | ||
|
cin
|
r39 | |||
|
cin
|
r18 | private _unregister(cb) { | ||
|
cin
|
r39 | if (this._cbs) { | ||
| const i = this._cbs.indexOf(cb); | ||||
| if (i >= 0) | ||||
| this._cbs.splice(i, 1); | ||||
| } | ||||
|
cin
|
r18 | } | ||
|
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 | |||
|
cin
|
r18 | register(_cb: (e: any) => void): IDestroyable { | ||
|
cin
|
r39 | return destroyed; | ||
|
cin
|
r13 | } | ||
| }; | ||||
|
cin
|
r39 | } | ||