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

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

working on fluent configuration, di annotations removed
working on fluent configuration, di annotations removed
cin - - Load All Authors

File last commit:

r134:511bcc634d65 ioc ts support
r134:511bcc634d65 ioc ts support
Show More
LifetimeManager.ts
176 lines | 4.8 KiB | video/mp2t | TypeScriptLexer
/ src / main / ts / di / LifetimeManager.ts
History | Source | Raw |Copy content |Copy permalink
cin
working on lifetime management
 r129 import { IDestroyable, MapOf } from "../interfaces";
import { argumentNotNull, isDestroyable } from "../safe";
cin
working on services lifetime
 r130 import { ILifetimeManager, ILifetime } from "./interfaces";
import { ActivationContext } from "./ActivationContext";
cin
working on fluent configuration, di annotations removed
 r134 import { Container } from "./Container";
cin
working on lifetime management
 r129
function safeCall(item: () => void) {
try {
item();
} catch {
cin
Refactoring, working on services lifetime
 r131 // silence!
cin
working on lifetime management
 r129 }
}
cin
Refactoring, working on services lifetime
 r131 const emptyLifetime: ILifetime = {
has() {
return false;
},
cin
working on fluent configuration, di annotations removed
 r134 initialize() {
cin
Refactoring, working on services lifetime
 r131
},
get() {
throw new Error("The specified item isn't registered with this lifetime manager");
},
store() {
// does nothing
}
};
cin
working on fluent configuration, di annotations removed
 r134 const unknownLifetime: ILifetime = {
has() {
throw new Error("The lifetime is unknown");
},
initialize() {
throw new Error("Can't call initialize on the unknown lifetime object");
},
get() {
throw new Error("The lifetime object isn't initialized");
},
store() {
throw new Error("Can't store a value in the unknown lifetime object");
}
}
cin
working on fluent configuration
 r133 let nextId = 0;
cin
working on lifetime management
 r129 export class LifetimeManager implements IDestroyable, ILifetimeManager {
private _cleanup: (() => void)[] = [];
private _cache: MapOf<any> = {};
private _destroyed = false;
cin
working on fluent configuration
 r132 private _pending: MapOf<boolean> = {};
cin
working on fluent configuration, di annotations removed
 r134 create(): ILifetime {
cin
working on services lifetime
 r130 const self = this;
cin
working on fluent configuration
 r133 const id = ++nextId;
cin
working on services lifetime
 r130 return {
has() {
return (id in self._cache);
},
get() {
const t = self._cache[id];
if (t === undefined)
throw new Error(`The item with with the key ${id} isn't found`);
return t;
},
cin
working on lifetime management
 r129
cin
working on fluent configuration, di annotations removed
 r134 initialize() {
cin
working on fluent configuration
 r132 if (self._pending[id])
cin
working on services lifetime
 r130 throw Error(`Cyclic reference detected: the item with the key ${id} is already activating.`);
cin
working on fluent configuration
 r132 self._pending[id] = true;
cin
working on services lifetime
 r130 },
store(item: any, cleanup?: (item: any) => void) {
argumentNotNull(id, "id");
argumentNotNull(item, "item");
if (this.has())
throw new Error(`The item with with the key ${id} already registered with this lifetime manager`);
cin
working on fluent configuration
 r132 delete self._pending[id];
cin
working on services lifetime
 r130
self._cache[id] = item;
if (self._destroyed)
throw new Error("Lifetime manager is destroyed");
if (cleanup) {
self._cleanup.push(() => cleanup(item));
} else if (isDestroyable(item)) {
self._cleanup.push(() => item.destroy());
}
}
};
cin
working on lifetime management
 r129 }
destroy() {
if (!this._destroyed) {
this._destroyed = true;
this._cleanup.forEach(safeCall);
this._cleanup.length = 0;
}
}
cin
working on fluent configuration, di annotations removed
 r134 static empty(): ILifetime {
return emptyLifetime;
}
static hierarchyLifetime(): ILifetime {
let _lifetime = unknownLifetime;
return {
initialize(context: ActivationContext<any>) {
if (_lifetime !== unknownLifetime)
throw new Error("Cyclic reference activation detected");
cin
Refactoring, working on services lifetime
 r131
cin
working on fluent configuration, di annotations removed
 r134 _lifetime = context.getContainer().getLifetimeManager().create(context);
},
get() {
return _lifetime.get();
},
has() {
return _lifetime.has();
},
store(item: any, cleanup?: (item: any) => void) {
return _lifetime.store(item, cleanup);
}
};
}
cin
working on lifetime management
 r129
cin
working on fluent configuration, di annotations removed
 r134 static contextLifetime(): ILifetime {
let _lifetime = unknownLifetime;
return {
initialize(context: ActivationContext<any>) {
if (_lifetime !== unknownLifetime)
throw new Error("Cyclic reference detected");
_lifetime = context.createLifetime();
},
get() {
return _lifetime.get();
},
has() {
return _lifetime.has();
},
store(item: any) {
_lifetime.store(item);
}
};
}
cin
working on fluent configuration
 r133
cin
working on fluent configuration, di annotations removed
 r134 static singletonLifetime(typeId: string): ILifetime {
return emptyLifetime;
}
static containerLifetime(container: Container<any>) {
let _lifetime = unknownLifetime;
cin
working on fluent configuration
 r133 return {
cin
working on fluent configuration, di annotations removed
 r134 initialize(context: ActivationContext<any>) {
if (_lifetime !== unknownLifetime)
throw new Error("Cyclic reference detected");
_lifetime = container.getLifetimeManager().create(context);
},
get() {
return _lifetime.get();
},
has() {
return _lifetime.has();
},
store(item: any) {
_lifetime.store(item);
cin
working on fluent configuration
 r133 }
};
}
cin
working on lifetime management
 r129 }