##// END OF EJS Templates
implab » implabjs-djx
RSS
Corrected Scope.own() to cleanup the supplied object immediately when the scope is disposed already
Corrected Scope.own() to cleanup the supplied object immediately when the scope is disposed already
cin - - Load All Authors

File last commit:

r131:c7d9ad82b374 v1.8.1 default
r131:c7d9ad82b374 v1.8.1 default
Show More
Scope.ts
54 lines | 1.4 KiB | video/mp2t | TypeScriptLexer
/ djx / src / main / ts / tsx / Scope.ts
History | Annotation | Raw |Copy content |Copy permalink
import { IDestroyable, IRemovable } from "@implab/core-amd/interfaces";
import { isDestroyable, isRemovable } from "@implab/core-amd/safe";
import { isUnsubscribable, Unsubscribable } from "../observable";
export interface IScope {
own(target: (() => void) | IDestroyable | IRemovable | Unsubscribable): void;
}
const guard = (cb: () => void) => {
try {
cb();
} catch {
// guard
}
};
export class Scope implements IDestroyable, IScope {
private readonly _pending: (() => void)[] = [];
private _disposed = false;
static readonly dummy: IScope = { own() { } };
own(target: (() => void) | IDestroyable | IRemovable | Unsubscribable) {
if (target instanceof Function) {
this._own(target);
} else if (isDestroyable(target)) {
this._own(() => target.destroy());
} else if (isRemovable(target)) {
this._own(() => target.remove());
} else if (isUnsubscribable(target)) {
this._own(() => target.unsubscribe());
}
}
private _own(target: () => void) {
if (this._disposed)
guard(target);
else
this._pending.push(target);
}
clean() {
this._pending.forEach(guard);
this._pending.length = 0;
}
destroy() {
if (!this._disposed) {
this._disposed = true;
this.clean();
}
}
}