| @@ -1,21 +1,55 | |||
|
|
1 | 1 | import { ICancellation } from "./interfaces"; |
|
|
2 | import { argumentNotNull } from "./safe"; | |
|
|
2 | 3 | |
|
|
3 | 4 | export class Cancellation implements ICancellation { |
|
|
5 | private _reason: any; | |
|
|
6 | private _cbs: Array<(e) => void>; | |
|
|
7 | ||
|
|
8 | constructor(action: (cancel: (e) => void) => void) { | |
|
|
9 | argumentNotNull(action, "action"); | |
|
|
10 | ||
|
|
11 | action(this._cancel.bind(this)); | |
|
|
12 | } | |
|
|
13 | ||
|
|
4 | 14 | isSupported(): boolean { |
|
|
5 |
return |
|
|
|
15 | return true; | |
|
|
6 | 16 | } |
|
|
7 | 17 | throwIfRequested(): void { |
|
|
18 | if (this._reason) | |
|
|
19 | throw this._reason; | |
|
|
8 | 20 | } |
|
|
9 | 21 | |
|
|
10 | 22 | isRequested(): boolean { |
|
|
11 |
return |
|
|
|
23 | return !!this._reason; | |
|
|
12 | 24 | } |
|
|
13 | 25 | |
|
|
14 |
register( |
|
|
|
26 | register(cb: (e: any) => void): void { | |
|
|
27 | argumentNotNull(cb, "cb"); | |
|
|
15 | 28 | |
|
|
29 | if (this._reason) { | |
|
|
30 | cb(this._reason); | |
|
|
31 | } else { | |
|
|
32 | if (!this._cbs) | |
|
|
33 | this._cbs = [cb]; | |
|
|
34 | else | |
|
|
35 | this._cbs.push(cb); | |
|
|
36 | } | |
|
|
16 | 37 | } |
|
|
17 | 38 | |
|
|
18 | static readonly none : Cancellation = { | |
|
|
39 | private _cancel(reason) { | |
|
|
40 | if (this._reason) | |
|
|
41 | return; | |
|
|
42 | ||
|
|
43 | this._reason = (reason = reason || new Error("Operation cancelled")); | |
|
|
44 | ||
|
|
45 | ||
|
|
46 | if (this._cbs) { | |
|
|
47 | this._cbs.forEach(cb => cb(reason)); | |
|
|
48 | this._cbs = null; | |
|
|
49 | } | |
|
|
50 | } | |
|
|
51 | ||
|
|
52 | static readonly none: ICancellation = { | |
|
|
19 | 53 | isSupported(): boolean { |
|
|
20 | 54 | return false; |
|
|
21 | 55 | }, |
General Comments 0
You need to be logged in to leave comments.
Login now