First Commit

src/observable.ts

@@ -0,0 +1,63 @@
+export type ObserverCallback<T> = (data: T[]) => void;
+
+export default class Observable<T = any> {
+   private subscriber: { callback: ObserverCallback<T>, one: boolean }[] = [];
+   private events: T[] = [];
+   private timeout: number | undefined = undefined;
+
+   constructor(private collect: boolean = true, private collect_intervall: number = 100) { }
+
+   /**
+    * Creates Public API with subscribe and unsubscribe
+    * 
+    * @returns {object}
+    */
+   getPublicApi() {
+      return {
+         /**
+          * Subscribe to Observable
+          * @param {function} callback
+          */
+         subscribe: (callback: ObserverCallback<T>, one: boolean = false) => {
+            let oldcb = this.subscriber.find(e => e.callback === callback);
+            if (oldcb)
+               oldcb.one = one
+            else
+               this.subscriber.push({ callback, one })
+         },
+         /**
+         * Subscribe fron Observable
+         * @param {function} callback
+         */
+         unsubscribe: (callback: ObserverCallback<T>) => {
+            let idx = this.subscriber.findIndex(e => e.callback === callback);
+            if (idx >= 0) {
+               this.subscriber.splice(idx, 1);
+            }
+         }
+      }
+   }
+
+   /**
+    * Sends data to all subscribers
+    * @param data data to be sent
+    */
+   send(data: T) {
+      if (!this.collect)
+         this.subscriber.forEach(e => e.callback([data]));
+      else {
+         this.events.push(data);
+         if (!this.timeout) {
+            this.timeout = setTimeout(() => {
+               this.subscriber.forEach(cb => {
+                  if (cb.one)
+                     this.events.forEach(e => cb.callback([e]));
+                  else
+                     cb.callback(this.events)
+               });
+               this.timeout = undefined;
+            }, this.collect_intervall);
+         }
+      }
+   }
+}