Cancellation.ts
88 lines
| 1.8 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 | ||
| let me = this; | |||
| return { | |||
| destroy() { | |||
| me._unregister(cb); | |||
| } | |||
| }; | |||
|
cin
|
r17 | } | |
|
cin
|
r13 | } | |
|
cin
|
r18 | ||
| private _unregister(cb) { | |||
| if(this._cbs) { | |||
| let i = this._cbs.indexOf(cb); | |||
| if ( i>=0 ) | |||
| this._cbs.splice(i,1); | |||
| } | |||
| } | |||
|
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 { | |
| return destroyed; | |||
|
cin
|
r13 | } | |
| }; | |||
| } |