1.0.27

README.md

@@ -22,7 +22,23 @@ We recommend the use of TypeScript for good intellisense.
 
 ```typescript
 // import any tool that you need from lik
-import { Stringmap, Objectmap } from "lik";
+import { Stringmap, Objectmap, Observablemap } from "lik";
 ```
 
-For a class overview, please read the docs
+### class Stringmap
+Stringmap allows you to keep track of strings. It allows you to register triggers for certain events
+like when a certain string is removed or added to the map
+
+### class Objectmap
+Sometimes you need to keep track of objects, but implementing logic for removing, finding or updating is tedious.
+Objectmap takes care of keeping track of objects for you.
+
+### class Observablemap
+Event Emitters are nice. However often times you end up with registering multiple listeners for the exact same thing.
+Observables have a smaller footprint and a more manageable subscribe logic.
+Observablemap registers only one rxjs observable per event and then continues to reference
+the same observable that you can subscribe to.
+
+**For a detailed class overview, please take a look at the API docs**
+
+[![npm](https://push.rocks/assets/repo-header.svg)](https://push.rocks)

dist/index.d.ts

@@ -1,2 +1,3 @@
 export * from './lik.stringmap';
 export * from './lik.objectmap';
+export * from './lik.observablemap';

dist/index.js

@@ -5,4 +5,5 @@ function __export(m) {
 // import modules
 __export(require("./lik.stringmap"));
 __export(require("./lik.objectmap"));
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBRUEsaUJBQWlCO0FBRWpCLHFDQUErQjtBQUMvQixxQ0FBK0IifQ==
+__export(require("./lik.observablemap"));
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBRUEsaUJBQWlCO0FBRWpCLHFDQUErQjtBQUMvQixxQ0FBK0I7QUFDL0IseUNBQW1DIn0=

dist/lik.objectmap.d.ts

@@ -18,9 +18,9 @@ export declare class Objectmap<T> {
      */
     add(objectArg: T): void;
     /**
-     * remove object from Objectmap
+     * like .add but adds an whole array of objects
      */
-    remove(objectArg: T): void;
+    addArray(objectArrayArg: T[]): void;
     /**
      * check if object is in Objectmap
      */
@@ -29,10 +29,30 @@ export declare class Objectmap<T> {
      * find object
      */
     find(findFunction: IObjectmapFindFunction<T>): T;
+    /**
+     * finds a specific element and then removes it
+     */
+    findOneAndRemove(findFunction: any): T;
     /**
      * run function for each item in Objectmap
      */
     forEach(functionArg: IObjectmapForEachFunction<T>): void;
+    /**
+     * gets an object in the Observablemap and removes it, so it can't be retrieved again
+     */
+    getOneAndRemove(): T;
+    /**
+     * returns a cloned array of all the objects currently in the Objectmap
+     */
+    getArray(): T[];
+    /**
+     * check if Objectmap ist empty
+     */
+    isEmpty(): boolean;
+    /**
+     * remove object from Objectmap
+     */
+    remove(objectArg: T): void;
     /**
      * wipe Objectmap
      */

dist/lik.objectmap.js

@@ -1,4 +1,5 @@
 "use strict";
+const plugins = require("./lik.plugins");
 /**
  * allows keeping track of objects
  */
@@ -16,16 +17,12 @@ class Objectmap {
         this.objectArray.push(objectArg);
     }
     /**
-     * remove object from Objectmap
+     * like .add but adds an whole array of objects
      */
-    remove(objectArg) {
-        let replacmentArray = [];
-        for (let item of this.objectArray) {
-            if (item !== objectArg) {
-                replacmentArray.push(item);
-            }
+    addArray(objectArrayArg) {
+        for (let item of objectArrayArg) {
+            this.add(item);
         }
-        this.objectArray = replacmentArray;
     }
     /**
      * check if object is in Objectmap
@@ -42,15 +39,60 @@ class Objectmap {
             return resultArray[0];
         }
         else {
-            return undefined;
+            return null;
         }
     }
+    /**
+     * finds a specific element and then removes it
+     */
+    findOneAndRemove(findFunction) {
+        let foundElement = this.find(findFunction);
+        if (foundElement) {
+            this.remove(foundElement);
+        }
+        return foundElement;
+    }
     /**
      * run function for each item in Objectmap
      */
     forEach(functionArg) {
         return this.objectArray.forEach(functionArg);
     }
+    /**
+     * gets an object in the Observablemap and removes it, so it can't be retrieved again
+     */
+    getOneAndRemove() {
+        return this.objectArray.shift();
+    }
+    /**
+     * returns a cloned array of all the objects currently in the Objectmap
+     */
+    getArray() {
+        return plugins.lodash.cloneDeep(this.objectArray);
+    }
+    /**
+     * check if Objectmap ist empty
+     */
+    isEmpty() {
+        if (this.objectArray.length === 0) {
+            return true;
+        }
+        else {
+            return false;
+        }
+    }
+    /**
+     * remove object from Objectmap
+     */
+    remove(objectArg) {
+        let replacementArray = [];
+        for (let item of this.objectArray) {
+            if (item !== objectArg) {
+                replacementArray.push(item);
+            }
+        }
+        this.objectArray = replacementArray;
+    }
     /**
      * wipe Objectmap
      */
@@ -59,4 +101,4 @@ class Objectmap {
     }
 }
 exports.Objectmap = Objectmap;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLm9iamVjdG1hcC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2xpay5vYmplY3RtYXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQVVBOztHQUVHO0FBQ0g7SUFHSTs7T0FFRztJQUNIO1FBTFEsZ0JBQVcsR0FBUSxFQUFFLENBQUE7SUFPN0IsQ0FBQztJQUVEOztPQUVHO0lBQ0gsR0FBRyxDQUFDLFNBQVk7UUFDWixJQUFJLENBQUMsV0FBVyxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsQ0FBQTtJQUNwQyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxNQUFNLENBQUMsU0FBWTtRQUNmLElBQUksZUFBZSxHQUFHLEVBQUUsQ0FBQTtRQUN4QixHQUFHLENBQUMsQ0FBQyxJQUFJLElBQUksSUFBSSxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsQ0FBQztZQUNoQyxFQUFFLENBQUMsQ0FBQyxJQUFJLEtBQUssU0FBUyxDQUFDLENBQUMsQ0FBQztnQkFDckIsZUFBZSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQTtZQUM5QixDQUFDO1FBQ0wsQ0FBQztRQUNELElBQUksQ0FBQyxXQUFXLEdBQUcsZUFBZSxDQUFBO0lBQ3RDLENBQUM7SUFFRDs7T0FFRztJQUNILGNBQWMsQ0FBQyxTQUFZO1FBQ3ZCLE1BQU0sQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsS0FBSyxDQUFDLENBQUMsQ0FBQTtJQUNyRCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxJQUFJLENBQUMsWUFBdUM7UUFDeEMsSUFBSSxXQUFXLEdBQUcsSUFBSSxDQUFDLFdBQVcsQ0FBQyxNQUFNLENBQUMsWUFBWSxDQUFDLENBQUE7UUFDdkQsRUFBRSxDQUFDLENBQUMsV0FBVyxDQUFDLE1BQU0sR0FBRyxDQUFDLENBQUMsQ0FBQyxDQUFDO1lBQ3pCLE1BQU0sQ0FBQyxXQUFXLENBQUMsQ0FBQyxDQUFDLENBQUE7UUFDekIsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ0osTUFBTSxDQUFDLFNBQVMsQ0FBQTtRQUNwQixDQUFDO0lBQ0wsQ0FBQztJQUVEOztPQUVHO0lBQ0gsT0FBTyxDQUFDLFdBQXlDO1FBQzdDLE1BQU0sQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxXQUFXLENBQUMsQ0FBQTtJQUNoRCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxJQUFJO1FBQ0EsSUFBSSxDQUFDLFdBQVcsR0FBRyxFQUFFLENBQUE7SUFDekIsQ0FBQztDQUNKO0FBOURELDhCQThEQyJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLm9iamVjdG1hcC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2xpay5vYmplY3RtYXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHlDQUF3QztBQVV4Qzs7R0FFRztBQUNIO0lBR0k7O09BRUc7SUFDSDtRQUxRLGdCQUFXLEdBQVEsRUFBRSxDQUFBO0lBTzdCLENBQUM7SUFFRDs7T0FFRztJQUNILEdBQUcsQ0FBQyxTQUFZO1FBQ1osSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLENBQUE7SUFDcEMsQ0FBQztJQUVEOztPQUVHO0lBQ0gsUUFBUSxDQUFDLGNBQW1CO1FBQ3hCLEdBQUcsQ0FBQyxDQUFDLElBQUksSUFBSSxJQUFJLGNBQWMsQ0FBQyxDQUFDLENBQUM7WUFDOUIsSUFBSSxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUNsQixDQUFDO0lBQ0wsQ0FBQztJQUVEOztPQUVHO0lBQ0gsY0FBYyxDQUFDLFNBQVk7UUFDdkIsTUFBTSxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFBO0lBQ3JELENBQUM7SUFFRDs7T0FFRztJQUNILElBQUksQ0FBQyxZQUF1QztRQUN4QyxJQUFJLFdBQVcsR0FBRyxJQUFJLENBQUMsV0FBVyxDQUFDLE1BQU0sQ0FBQyxZQUFZLENBQUMsQ0FBQTtRQUN2RCxFQUFFLENBQUMsQ0FBQyxXQUFXLENBQUMsTUFBTSxHQUFHLENBQUMsQ0FBQyxDQUFDLENBQUM7WUFDekIsTUFBTSxDQUFDLFdBQVcsQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUN6QixDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDSixNQUFNLENBQUMsSUFBSSxDQUFBO1FBQ2YsQ0FBQztJQUNMLENBQUM7SUFFRDs7T0FFRztJQUNILGdCQUFnQixDQUFDLFlBQVk7UUFDekIsSUFBSSxZQUFZLEdBQUcsSUFBSSxDQUFDLElBQUksQ0FBQyxZQUFZLENBQUMsQ0FBQTtRQUMxQyxFQUFFLENBQUMsQ0FBQyxZQUFZLENBQUMsQ0FBQyxDQUFDO1lBQ2YsSUFBSSxDQUFDLE1BQU0sQ0FBQyxZQUFZLENBQUMsQ0FBQTtRQUM3QixDQUFDO1FBQ0QsTUFBTSxDQUFDLFlBQVksQ0FBQTtJQUN2QixDQUFDO0lBRUQ7O09BRUc7SUFDSCxPQUFPLENBQUMsV0FBeUM7UUFDN0MsTUFBTSxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsT0FBTyxDQUFDLFdBQVcsQ0FBQyxDQUFBO0lBQ2hELENBQUM7SUFFRDs7T0FFRztJQUNILGVBQWU7UUFDWCxNQUFNLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxLQUFLLEVBQUUsQ0FBQTtJQUNuQyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxRQUFRO1FBQ0osTUFBTSxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsU0FBUyxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsQ0FBQTtJQUNyRCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxPQUFPO1FBQ0gsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxNQUFNLEtBQUssQ0FBQyxDQUFDLENBQUMsQ0FBQztZQUNoQyxNQUFNLENBQUMsSUFBSSxDQUFBO1FBQ2YsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ0osTUFBTSxDQUFDLEtBQUssQ0FBQTtRQUNoQixDQUFDO0lBQ0wsQ0FBQztJQUVEOztPQUVHO0lBQ0gsTUFBTSxDQUFDLFNBQVk7UUFDZixJQUFJLGdCQUFnQixHQUFHLEVBQUUsQ0FBQTtRQUN6QixHQUFHLENBQUMsQ0FBQyxJQUFJLElBQUksSUFBSSxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsQ0FBQztZQUNoQyxFQUFFLENBQUMsQ0FBQyxJQUFJLEtBQUssU0FBUyxDQUFDLENBQUMsQ0FBQztnQkFDckIsZ0JBQWdCLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxDQUFBO1lBQy9CLENBQUM7UUFDTCxDQUFDO1FBQ0QsSUFBSSxDQUFDLFdBQVcsR0FBRyxnQkFBZ0IsQ0FBQTtJQUN2QyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxJQUFJO1FBQ0EsSUFBSSxDQUFDLFdBQVcsR0FBRyxFQUFFLENBQUE7SUFDekIsQ0FBQztDQUNKO0FBM0dELDhCQTJHQyJ9

dist/lik.observablemap.d.ts

@@ -0,0 +1,23 @@
+/// <reference types="node" />
+import * as plugins from './lik.plugins';
+import { Objectmap } from './lik.objectmap';
+import { Observable } from 'rxjs/Rx';
+/**
+ * bundles an observable with an emitter
+ */
+export interface ObservableEmitterBundle {
+    observable: plugins.rx.Observable<any>;
+    emitter: plugins.events.EventEmitter;
+    event: string;
+}
+/**
+ * manages observables by making sure that only one observable is regsitered per event
+ */
+export declare class Observablemap {
+    ObservableEmitterBundleObjectmap: Objectmap<ObservableEmitterBundle>;
+    /**
+     * creates a new observable if not yet registered for the same event.
+     * In case event has been registered before the same observable is returned.
+     */
+    getObservableForEmitterEvent(emitterArg: plugins.events.EventEmitter, eventArg: string): Observable<any>;
+}

dist/lik.observablemap.js

@@ -0,0 +1,34 @@
+"use strict";
+const plugins = require("./lik.plugins");
+const lik_objectmap_1 = require("./lik.objectmap");
+/**
+ * manages observables by making sure that only one observable is regsitered per event
+ */
+class Observablemap {
+    constructor() {
+        this.ObservableEmitterBundleObjectmap = new lik_objectmap_1.Objectmap();
+    }
+    /**
+     * creates a new observable if not yet registered for the same event.
+     * In case event has been registered before the same observable is returned.
+     */
+    getObservableForEmitterEvent(emitterArg, eventArg) {
+        let existingBundle = this.ObservableEmitterBundleObjectmap.find((bundleArg) => {
+            return (bundleArg.emitter === emitterArg && bundleArg.event === eventArg);
+        });
+        if (existingBundle) {
+            return existingBundle.observable;
+        }
+        else {
+            let emitterObservable = plugins.rx.Observable.fromEvent(emitterArg, eventArg);
+            this.ObservableEmitterBundleObjectmap.add({
+                observable: emitterObservable,
+                emitter: emitterArg,
+                event: eventArg
+            });
+            return emitterObservable;
+        }
+    }
+}
+exports.Observablemap = Observablemap;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLm9ic2VydmFibGVtYXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9saWsub2JzZXJ2YWJsZW1hcC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEseUNBQXdDO0FBQ3hDLG1EQUEyQztBQWMzQzs7R0FFRztBQUNIO0lBQUE7UUFDSSxxQ0FBZ0MsR0FBRyxJQUFJLHlCQUFTLEVBQTJCLENBQUE7SUFzQi9FLENBQUM7SUFwQkc7OztPQUdHO0lBQ0gsNEJBQTRCLENBQUMsVUFBdUMsRUFBRSxRQUFnQjtRQUNsRixJQUFJLGNBQWMsR0FBRyxJQUFJLENBQUMsZ0NBQWdDLENBQUMsSUFBSSxDQUFDLENBQUMsU0FBUztZQUN0RSxNQUFNLENBQUEsQ0FBQyxTQUFTLENBQUMsT0FBTyxLQUFLLFVBQVUsSUFBSSxTQUFTLENBQUMsS0FBSyxLQUFLLFFBQVEsQ0FBQyxDQUFBO1FBQzVFLENBQUMsQ0FBQyxDQUFBO1FBQ0YsRUFBRSxDQUFDLENBQUMsY0FBYyxDQUFDLENBQUMsQ0FBQztZQUNqQixNQUFNLENBQUMsY0FBYyxDQUFDLFVBQVUsQ0FBQTtRQUNwQyxDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDSixJQUFJLGlCQUFpQixHQUFHLE9BQU8sQ0FBQyxFQUFFLENBQUMsVUFBVSxDQUFDLFNBQVMsQ0FBQyxVQUFVLEVBQUUsUUFBUSxDQUFDLENBQUE7WUFDN0UsSUFBSSxDQUFDLGdDQUFnQyxDQUFDLEdBQUcsQ0FBQztnQkFDdEMsVUFBVSxFQUFFLGlCQUFpQjtnQkFDN0IsT0FBTyxFQUFFLFVBQVU7Z0JBQ25CLEtBQUssRUFBRSxRQUFRO2FBQ2xCLENBQUMsQ0FBQTtZQUNGLE1BQU0sQ0FBQyxpQkFBaUIsQ0FBQTtRQUM1QixDQUFDO0lBQ0wsQ0FBQztDQUNKO0FBdkJELHNDQXVCQyJ9

dist/lik.plugins.d.ts

@@ -1,4 +1,6 @@
 import 'typings-global';
 export import q = require('q');
+export import events = require('events');
 export import lodash = require('lodash');
 export import minimatch = require('minimatch');
+export import rx = require('rxjs/Rx');

dist/lik.plugins.js

@@ -1,6 +1,8 @@
 "use strict";
 require("typings-global");
 exports.q = require("q");
+exports.events = require("events");
 exports.lodash = require("lodash");
 exports.minimatch = require("minimatch");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnBsdWdpbnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9saWsucGx1Z2lucy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXVCO0FBQ3ZCLHlCQUE4QjtBQUM5QixtQ0FBd0M7QUFDeEMseUNBQThDIn0=
+exports.rx = require("rxjs/Rx");
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnBsdWdpbnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9saWsucGx1Z2lucy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXVCO0FBQ3ZCLHlCQUE4QjtBQUM5QixtQ0FBd0M7QUFDeEMsbUNBQXdDO0FBQ3hDLHlDQUE4QztBQUM5QyxnQ0FBcUMifQ==

dist/lik.stringmap.d.ts

@@ -12,6 +12,10 @@ export declare class Stringmap {
      * add a string to the Stringmap
      */
     addString(stringArg: string): void;
+    /**
+     * like addString, but accepts an array of strings
+     */
+    addStringArray(stringArrayArg: string[]): void;
     /**
      * removes a string from Stringmap
      */

dist/lik.stringmap.js

@@ -12,6 +12,14 @@ class Stringmap {
         this._stringArray.push(stringArg);
         this.notifyTrigger();
     }
+    /**
+     * like addString, but accepts an array of strings
+     */
+    addStringArray(stringArrayArg) {
+        for (let stringItem of stringArrayArg) {
+            this.addString(stringItem);
+        }
+    }
     /**
      * removes a string from Stringmap
      */
@@ -85,4 +93,4 @@ class Stringmap {
     }
 }
 exports.Stringmap = Stringmap;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnN0cmluZ21hcC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2xpay5zdHJpbmdtYXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHlDQUF3QztBQVV4QztJQUdJO1FBRlEsaUJBQVksR0FBYSxFQUFFLENBQUE7UUFDM0IsbUNBQThCLEdBQXVCLEVBQUUsQ0FBQTtJQUNoRCxDQUFDO0lBQ2hCOztPQUVHO0lBQ0gsU0FBUyxDQUFDLFNBQWlCO1FBQ3ZCLElBQUksQ0FBQyxZQUFZLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBQ2pDLElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSCxZQUFZLENBQUMsU0FBaUI7UUFDMUIsR0FBRyxDQUFDLENBQUMsSUFBSSxNQUFNLElBQUksSUFBSSxDQUFDLFlBQVksQ0FBQyxDQUFDLENBQUM7WUFDbkMsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxNQUFNLENBQUMsS0FBSyxTQUFTLENBQUMsQ0FBQyxDQUFDO2dCQUMxQyxJQUFJLENBQUMsWUFBWSxDQUFDLE1BQU0sQ0FBQyxRQUFRLENBQUMsTUFBTSxDQUFDLEVBQUMsQ0FBQyxDQUFDLENBQUE7WUFDaEQsQ0FBQztRQUNMLENBQUM7UUFDRCxJQUFJLENBQUMsYUFBYSxFQUFFLENBQUE7SUFDeEIsQ0FBQztJQUVEOztPQUVHO0lBQ0gsSUFBSTtRQUNBLElBQUksQ0FBQyxZQUFZLEdBQUcsRUFBRSxDQUFBO1FBQ3RCLElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSCxXQUFXLENBQUMsU0FBaUI7UUFDekIsTUFBTSxDQUFDLElBQUksQ0FBQyxZQUFZLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFBO0lBQ3RELENBQUM7SUFFRDs7T0FFRztJQUNILGNBQWMsQ0FBQyxrQkFBMEI7UUFDckMsSUFBSSxVQUFVLEdBQVksS0FBSyxDQUFBO1FBQy9CLEdBQUcsQ0FBQyxDQUFDLElBQUksVUFBVSxJQUFJLElBQUksQ0FBQyxZQUFZLENBQUMsQ0FBQSxDQUFDO1lBQ3RDLEVBQUUsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBVSxFQUFDLGtCQUFrQixDQUFDLENBQUMsQ0FBQyxDQUFDO2dCQUNuRCxVQUFVLEdBQUcsSUFBSSxDQUFBO1lBQ3JCLENBQUM7UUFDTCxDQUFDO1FBQ0QsTUFBTSxDQUFDLFVBQVUsQ0FBQTtJQUNyQixDQUFDO0lBRUQ7O09BRUc7SUFDSCxZQUFZO1FBQ1IsTUFBTSxDQUFDLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxNQUFNLEtBQUssQ0FBQyxDQUFDLENBQUE7SUFDM0MsQ0FBQztJQUVEOztPQUVHO0lBQ0gsY0FBYztRQUNWLE1BQU0sQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLENBQUE7SUFDdEQsQ0FBQztJQUVELHNCQUFzQjtJQUV0Qjs7T0FFRztJQUNILGlCQUFpQixDQUFDLFdBQTZCLEVBQUMsYUFBYTtRQUN6RCxJQUFJLENBQUMsOEJBQThCLENBQUMsSUFBSSxDQUNwQztZQUNJLElBQUksTUFBTSxHQUFHLFdBQVcsRUFBRSxDQUFBO1lBQzFCLEVBQUUsQ0FBQyxDQUFDLE1BQU0sS0FBSyxJQUFJLENBQUMsQ0FBQyxDQUFDO2dCQUNsQixhQUFhLEVBQUUsQ0FBQTtZQUNuQixDQUFDO1lBQ0QsTUFBTSxDQUFDLE1BQU0sQ0FBQTtRQUNqQixDQUFDLENBQ0osQ0FBQTtRQUNELElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSyxhQUFhO1FBQ2pCLElBQUksYUFBYSxHQUFHLElBQUksQ0FBQyw4QkFBOEIsQ0FBQyxNQUFNLENBQUMsQ0FBQyxXQUFXO1lBQ3ZFLE1BQU0sQ0FBQyxDQUFDLFdBQVcsRUFBRSxDQUFBO1FBQ3pCLENBQUMsQ0FBQyxDQUFBO1FBQ0YsSUFBSSxDQUFDLDhCQUE4QixHQUFHLGFBQWEsQ0FBQTtJQUN2RCxDQUFDO0NBRUo7QUE5RkQsOEJBOEZDIn0=
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnN0cmluZ21hcC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2xpay5zdHJpbmdtYXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHlDQUF3QztBQVV4QztJQUdJO1FBRlEsaUJBQVksR0FBYSxFQUFFLENBQUE7UUFDM0IsbUNBQThCLEdBQXVCLEVBQUUsQ0FBQTtJQUNoRCxDQUFDO0lBQ2hCOztPQUVHO0lBQ0gsU0FBUyxDQUFDLFNBQWlCO1FBQ3ZCLElBQUksQ0FBQyxZQUFZLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBQ2pDLElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSCxjQUFjLENBQUMsY0FBd0I7UUFDbkMsR0FBRyxDQUFDLENBQUMsSUFBSSxVQUFVLElBQUksY0FBYyxDQUFDLENBQUEsQ0FBQztZQUNuQyxJQUFJLENBQUMsU0FBUyxDQUFDLFVBQVUsQ0FBQyxDQUFBO1FBQzlCLENBQUM7SUFDTCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxZQUFZLENBQUMsU0FBaUI7UUFDMUIsR0FBRyxDQUFDLENBQUMsSUFBSSxNQUFNLElBQUksSUFBSSxDQUFDLFlBQVksQ0FBQyxDQUFDLENBQUM7WUFDbkMsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxNQUFNLENBQUMsS0FBSyxTQUFTLENBQUMsQ0FBQyxDQUFDO2dCQUMxQyxJQUFJLENBQUMsWUFBWSxDQUFDLE1BQU0sQ0FBQyxRQUFRLENBQUMsTUFBTSxDQUFDLEVBQUMsQ0FBQyxDQUFDLENBQUE7WUFDaEQsQ0FBQztRQUNMLENBQUM7UUFDRCxJQUFJLENBQUMsYUFBYSxFQUFFLENBQUE7SUFDeEIsQ0FBQztJQUVEOztPQUVHO0lBQ0gsSUFBSTtRQUNBLElBQUksQ0FBQyxZQUFZLEdBQUcsRUFBRSxDQUFBO1FBQ3RCLElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSCxXQUFXLENBQUMsU0FBaUI7UUFDekIsTUFBTSxDQUFDLElBQUksQ0FBQyxZQUFZLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFBO0lBQ3RELENBQUM7SUFFRDs7T0FFRztJQUNILGNBQWMsQ0FBQyxrQkFBMEI7UUFDckMsSUFBSSxVQUFVLEdBQVksS0FBSyxDQUFBO1FBQy9CLEdBQUcsQ0FBQyxDQUFDLElBQUksVUFBVSxJQUFJLElBQUksQ0FBQyxZQUFZLENBQUMsQ0FBQSxDQUFDO1lBQ3RDLEVBQUUsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBVSxFQUFDLGtCQUFrQixDQUFDLENBQUMsQ0FBQyxDQUFDO2dCQUNuRCxVQUFVLEdBQUcsSUFBSSxDQUFBO1lBQ3JCLENBQUM7UUFDTCxDQUFDO1FBQ0QsTUFBTSxDQUFDLFVBQVUsQ0FBQTtJQUNyQixDQUFDO0lBRUQ7O09BRUc7SUFDSCxZQUFZO1FBQ1IsTUFBTSxDQUFDLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxNQUFNLEtBQUssQ0FBQyxDQUFDLENBQUE7SUFDM0MsQ0FBQztJQUVEOztPQUVHO0lBQ0gsY0FBYztRQUNWLE1BQU0sQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLENBQUE7SUFDdEQsQ0FBQztJQUVELHNCQUFzQjtJQUV0Qjs7T0FFRztJQUNILGlCQUFpQixDQUFDLFdBQTZCLEVBQUMsYUFBYTtRQUN6RCxJQUFJLENBQUMsOEJBQThCLENBQUMsSUFBSSxDQUNwQztZQUNJLElBQUksTUFBTSxHQUFHLFdBQVcsRUFBRSxDQUFBO1lBQzFCLEVBQUUsQ0FBQyxDQUFDLE1BQU0sS0FBSyxJQUFJLENBQUMsQ0FBQyxDQUFDO2dCQUNsQixhQUFhLEVBQUUsQ0FBQTtZQUNuQixDQUFDO1lBQ0QsTUFBTSxDQUFDLE1BQU0sQ0FBQTtRQUNqQixDQUFDLENBQ0osQ0FBQTtRQUNELElBQUksQ0FBQyxhQUFhLEVBQUUsQ0FBQTtJQUN4QixDQUFDO0lBRUQ7O09BRUc7SUFDSyxhQUFhO1FBQ2pCLElBQUksYUFBYSxHQUFHLElBQUksQ0FBQyw4QkFBOEIsQ0FBQyxNQUFNLENBQUMsQ0FBQyxXQUFXO1lBQ3ZFLE1BQU0sQ0FBQyxDQUFDLFdBQVcsRUFBRSxDQUFBO1FBQ3pCLENBQUMsQ0FBQyxDQUFBO1FBQ0YsSUFBSSxDQUFDLDhCQUE4QixHQUFHLGFBQWEsQ0FBQTtJQUN2RCxDQUFDO0NBRUo7QUF2R0QsOEJBdUdDIn0=

package.json

@@ -1,6 +1,6 @@
 {
   "name": "lik",
-  "version": "1.0.18",
+  "version": "1.0.27",
   "description": "light little helpers for node",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
@@ -29,6 +29,8 @@
     "@types/q": "0.x.x",
     "lodash": "^4.16.1",
     "minimatch": "^3.0.3",
-    "q": "^1.4.1"
+    "q": "^1.4.1",
+    "rxjs": "^5.0.0-beta.12",
+    "typings-global": "^1.0.14"
   }
 }

test/test.ts

@@ -1,21 +1,26 @@
 import 'typings-test'
-import lik = require('../dist/index')
+import * as events from 'events'
+import * as rx from 'rxjs/Rx'
 import * as should from 'should'
 
+import lik = require('../dist/index')
 describe('lik',function(){
     describe('Stringmap',function(){
         let testStringmap: lik.Stringmap
         let testString1 = 'testString1'
         let testString2 = 'testString2'
         let testString3 = 'testString3'
-        it('should create an instance of Stringmap',function(){
+        let testString4 = 'testString4'
+        let testString5 = 'testString5'
+        let testString6 = 'testString6'
+        it('new lik.Objectmap() -> should create an instance of Stringmap',function(){
             testStringmap = new lik.Stringmap()
             should(testStringmap).be.instanceof(lik.Stringmap)
         })
-        it('should return false for an string not in Stringmap',function(){
+        it('lik.Stringmap.checkString -> should return false for an string not in Stringmap',function(){
             should(testStringmap.checkString(testString1)).be.false()
         })
-        it('should add an string to Stringmap',function(){
+        it('lik.Stringmap.addString -> should add an string to Stringmap',function(){
             testStringmap.addString(testString1)
             testStringmap.addString(testString2)
             testStringmap.addString(testString3)
@@ -26,22 +31,26 @@ describe('lik',function(){
             should(testStringmap.checkMinimatch('*String2')).be.true()
             should(testStringmap.checkMinimatch('*String4')).be.false()
         })
-        it('should remove a string from Stringmap',function(){
+        it('lik.Stringmap.addStringArray -> should add an array of strings',function(){
+            testStringmap.addStringArray([testString4,testString5,testString6])
+            should(testStringmap.checkMinimatch('*String4')).be.true()
+        })
+        it('lik.Stringmap.removeString -> should remove a string from Stringmap',function(){
             testStringmap.removeString(testString2)
             should(testStringmap.checkString(testString2)).be.false()
         })
-        it('should return a copy of stringArray',function(){
+        it('lik.Stringmap.getStringArray() -> should return a copy of stringArray',function(){
             let clonedArray = testStringmap.getStringArray()
             should(clonedArray[0] === 'testString1').be.true()
             should(clonedArray[0] === testString1).be.true()
         })
-        it('should register a function to trigger when empty',function(){
+        it('lik.Stringmap.checkIsEmpty() -> should register a function to trigger when empty',function(){
             testStringmap.registerUntilTrue(
                 () => { return testStringmap.checkIsEmpty() },
                 () => { console.log('Stringmap now is empty') }
             )
         })
-        it('should remove wipe and then notify',function(){
+        it('lik.Stringmap.empty() -> should remove wipe and then notify',function(){
             testStringmap.wipe()
         })
     })
@@ -59,31 +68,67 @@ describe('lik',function(){
             propOne: 'hello',
             propTwo: 'hello2'
         }
-        it('should correctly instantiate an Objectmap',function(){
+        it('new lik.Objectmap() -> should correctly instantiate an Objectmap',function(){
             testObjectmap = new lik.Objectmap<ITestObject>()
             should(testObjectmap).be.instanceof(lik.Objectmap)
         })
-        it('should correctly add an object to Objectmap',function(){
+        it('lik.Objectmap.add() -> should correctly add an object to Objectmap',function(){
             testObjectmap.add(testObject1)
             should(testObjectmap.checkForObject(testObject1)).be.true
             should(testObjectmap.checkForObject(testObject2)).be.false
         })
-        it('should correctly remove an object to Objectmap',function(){
+        it('lik.Objectmap.remove() -> should correctly remove an object to Objectmap',function(){
             testObjectmap.add(testObject2)
             testObjectmap.remove(testObject1)
             should(testObjectmap.checkForObject(testObject1)).be.false
             should(testObjectmap.checkForObject(testObject2)).be.true
         })
-        it('should correctly run a function forEach map object',function(){
+        it('Objectmap.forEach -> should correctly run a function forEach map object',function(){
             testObjectmap.forEach(itemArg => {
                 should(itemArg).have.ownProperty('propOne')
             })
         })
-        it('should correctly find an object',function(){
+        it('lik.Objectmap.find() -> should correctly find an object',function(){
             let myObject = {propOne: 'helloThere', propTwo: 'helloAnyway'}
             testObjectmap.add(myObject)
             let referenceObject = testObjectmap.find((itemArg) => { return (itemArg.propOne === 'helloThere') })
             should(myObject === referenceObject).be.true()
         })
+        it('lik.Objectmap.getArray() -> should return a cloned array', function(){
+            let myObject = {propOne : 'test1', propTwo: 'wow, how awesome'}
+            testObjectmap.add(myObject)
+            let clonedArray = testObjectmap.getArray()
+            should(clonedArray[clonedArray.length - 1]).eql(myObject)
+        })
+        it('should get one object and then remove it', function() {
+            let originalLength = testObjectmap.getArray().length
+            let oneObject = testObjectmap.getOneAndRemove()
+            should(oneObject).not.be.null()
+            should(testObjectmap.getArray().length).equal(originalLength - 1)
+            should(testObjectmap.getArray()).not.containEql(oneObject)
+        })
+    })
+    describe('Observablemap',function(){
+        let testObservablemap: lik.Observablemap
+        let testObservable1: rx.Observable<any>
+        let testObservable2: rx.Observable<any>
+        let testObservable3: rx.Observable<any>
+        let testEmitter: events.EventEmitter
+        it('should create an instance',function(){
+            testObservablemap = new lik.Observablemap()
+            should(testObservablemap).be.instanceof(lik.Observablemap)
+        })
+        it('should accept a new emitter',function(done) {
+            testEmitter = new events.EventEmitter()
+            testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter,'event1')
+            testObservable1.subscribe(x => {
+                done()
+            })
+            testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter,'event1')
+            testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2')
+            should(testObservable1 === testObservable2).be.true()
+            should(testObservable1 === testObservable3).be.false()
+            testEmitter.emit('event1')
+        })
     })
 })

ts/index.ts

@@ -4,3 +4,4 @@ import * as plugins from './lik.plugins'
 
 export * from './lik.stringmap'
 export * from './lik.objectmap'
+export * from './lik.observablemap'

ts/lik.objectmap.ts

@@ -29,16 +29,12 @@ export class Objectmap<T> {
     }
 
     /**
-     * remove object from Objectmap
+     * like .add but adds an whole array of objects
      */
-    remove(objectArg: T) {
-        let replacmentArray = []
-        for (let item of this.objectArray) {
-            if (item !== objectArg) {
-                replacmentArray.push(item)
-            }
+    addArray(objectArrayArg: T[]) {
+        for (let item of objectArrayArg) {
+            this.add(item)
         }
-        this.objectArray = replacmentArray
     }
 
     /**
@@ -56,10 +52,21 @@ export class Objectmap<T> {
         if (resultArray.length > 0) {
             return resultArray[0]
         } else {
-            return undefined
+            return null
         }
     }
 
+    /**
+     * finds a specific element and then removes it
+     */
+    findOneAndRemove(findFunction): T {
+        let foundElement = this.find(findFunction)
+        if (foundElement) {
+            this.remove(foundElement)
+        }
+        return foundElement
+    }
+
     /**
      * run function for each item in Objectmap
      */
@@ -67,6 +74,44 @@ export class Objectmap<T> {
         return this.objectArray.forEach(functionArg)
     }
 
+    /**
+     * gets an object in the Observablemap and removes it, so it can't be retrieved again
+     */
+    getOneAndRemove(): T {
+        return this.objectArray.shift()
+    }
+
+    /**
+     * returns a cloned array of all the objects currently in the Objectmap
+     */
+    getArray() {
+        return plugins.lodash.cloneDeep(this.objectArray)
+    }
+
+    /**
+     * check if Objectmap ist empty
+     */
+    isEmpty(): boolean {
+        if (this.objectArray.length === 0) {
+            return true
+        } else {
+            return false
+        }
+    }
+
+    /**
+     * remove object from Objectmap
+     */
+    remove(objectArg: T) {
+        let replacementArray = []
+        for (let item of this.objectArray) {
+            if (item !== objectArg) {
+                replacementArray.push(item)
+            }
+        }
+        this.objectArray = replacementArray
+    }
+
     /**
      * wipe Objectmap
      */

ts/lik.observablemap.ts

@@ -0,0 +1,42 @@
+import * as plugins from './lik.plugins'
+import { Objectmap } from './lik.objectmap'
+import { Stringmap } from './lik.stringmap'
+import { Observable } from 'rxjs/Rx'
+
+
+/**
+ * bundles an observable with an emitter
+ */
+export interface ObservableEmitterBundle {
+    observable: plugins.rx.Observable<any>
+    emitter: plugins.events.EventEmitter
+    event: string
+}
+
+/**
+ * manages observables by making sure that only one observable is regsitered per event
+ */
+export class Observablemap {
+    ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>()
+
+    /**
+     * creates a new observable if not yet registered for the same event.
+     * In case event has been registered before the same observable is returned.
+     */
+    getObservableForEmitterEvent(emitterArg: plugins.events.EventEmitter, eventArg: string) {
+        let existingBundle = this.ObservableEmitterBundleObjectmap.find((bundleArg) => {
+            return(bundleArg.emitter === emitterArg && bundleArg.event === eventArg)
+        })
+        if (existingBundle) {
+            return existingBundle.observable
+        } else {
+            let emitterObservable = plugins.rx.Observable.fromEvent(emitterArg, eventArg)
+            this.ObservableEmitterBundleObjectmap.add({
+                observable: emitterObservable,
+                emitter: emitterArg,
+                event: eventArg
+            })
+            return emitterObservable
+        }
+    }
+}

ts/lik.plugins.ts

@@ -1,4 +1,6 @@
 import 'typings-global'
 export import q = require('q')
+export import events = require('events')
 export import lodash = require('lodash')
 export import minimatch = require('minimatch')
+export import rx = require('rxjs/Rx')