Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
e1442b1bc8 | |||
2ca9e14f76 |
2
package-lock.json
generated
2
package-lock.json
generated
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/lik",
|
"name": "@pushrocks/lik",
|
||||||
"version": "3.0.12",
|
"version": "3.0.13",
|
||||||
"lockfileVersion": 1,
|
"lockfileVersion": 1,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/lik",
|
"name": "@pushrocks/lik",
|
||||||
"version": "3.0.12",
|
"version": "3.0.13",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "light little helpers for node",
|
"description": "light little helpers for node",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
|
@ -14,6 +14,9 @@ export interface IObjectmapFindFunction<T> {
|
|||||||
export class Objectmap<T> {
|
export class Objectmap<T> {
|
||||||
private objectArray: T[] = [];
|
private objectArray: T[] = [];
|
||||||
|
|
||||||
|
// events
|
||||||
|
public eventSubject = new plugins.smartrx.rxjs.Subject<any>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* returns a new instance
|
* returns a new instance
|
||||||
*/
|
*/
|
||||||
@ -33,6 +36,7 @@ export class Objectmap<T> {
|
|||||||
} else {
|
} else {
|
||||||
// the object is not yet in the objectmap
|
// the object is not yet in the objectmap
|
||||||
this.objectArray.push(objectArg);
|
this.objectArray.push(objectArg);
|
||||||
|
this.eventSubject.next('add');
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -89,7 +93,9 @@ export class Objectmap<T> {
|
|||||||
* gets an object in the Observablemap and removes it, so it can't be retrieved again
|
* gets an object in the Observablemap and removes it, so it can't be retrieved again
|
||||||
*/
|
*/
|
||||||
public getOneAndRemove(): T {
|
public getOneAndRemove(): T {
|
||||||
return this.objectArray.shift();
|
const removedItem = this.objectArray.shift();
|
||||||
|
this.eventSubject.next('remove');
|
||||||
|
return removedItem;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -125,6 +131,7 @@ export class Objectmap<T> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
this.objectArray = replacementArray;
|
this.objectArray = replacementArray;
|
||||||
|
this.eventSubject.next('remove');
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -132,5 +139,6 @@ export class Objectmap<T> {
|
|||||||
*/
|
*/
|
||||||
public wipe() {
|
public wipe() {
|
||||||
this.objectArray = [];
|
this.objectArray = [];
|
||||||
|
this.eventSubject.next('wiped');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user