##// END OF EJS Templates
implab » implabjs-core
RSS

Clone from http://hg.code.sf.net/p/implabjs/core

added provided and configure methods to the fluent container configuration, added applyConfig method to the container
added provided and configure methods to the fluent container configuration, added applyConfig method to the container
cin - - Load All Authors

File last commit:

r115:691199f665e0 ioc ts support
r142:be7edf08a115 v1.4.0-rc3 default
Show More
Cancellation.ts
83 lines | 1.9 KiB | video/mp2t | TypeScriptLexer
/ src / main / ts / Cancellation.ts
History | Annotation | Raw |Copy content |Copy permalink
import { ICancellation, IDestroyable } from "./interfaces";
import { argumentNotNull, destroyed } from "./safe";
export class Cancellation implements ICancellation {
private _reason: any;
private _cbs: Array<(e: any) => void> | undefined;
constructor(action: (cancel: (e?: any) => void) => void) {
argumentNotNull(action, "action");
action(this._cancel.bind(this));
}
isSupported(): boolean {
return true;
}
throwIfRequested(): void {
if (this._reason)
throw this._reason;
}
isRequested(): boolean {
return !!this._reason;
}
register(cb: (e: any) => void): IDestroyable {
argumentNotNull(cb, "cb");
if (this._reason) {
cb(this._reason);
return destroyed;
} else {
if (!this._cbs)
this._cbs = [cb];
else
this._cbs.push(cb);
const me = this;
return {
destroy() {
me._unregister(cb);
}
};
}
}
private _unregister(cb: any) {
if (this._cbs) {
const i = this._cbs.indexOf(cb);
if (i >= 0)
this._cbs.splice(i, 1);
}
}
private _cancel(reason: any) {
if (this._reason)
return;
this._reason = (reason = reason || new Error("Operation cancelled"));
if (this._cbs) {
this._cbs.forEach(cb => cb(reason));
this._cbs = undefined;
}
}
static readonly none: ICancellation = {
isSupported(): boolean {
return false;
},
throwIfRequested(): void {
},
isRequested(): boolean {
return false;
},
register(_cb: (e: any) => void): IDestroyable {
return destroyed;
}
};
}