##// END OF EJS Templates
implab » implabjs-djx
RSS
Added a fallback error handler to observables, it will report unhandled errors
Added a fallback error handler to observables, it will report unhandled errors
cin - - Load All Authors

File last commit:

r131:c7d9ad82b374 v1.8.1 default
r138:98b2c550c676 v1.9.0-rc3 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();
}
}
}