cleaned up and moved multiplexer

Author: theodorDiaconu

lib/cache/ObservableCollection.js

@@ -176,16 +176,6 @@ export default class ObservableCollection {
         return this.store.has(docId);
     }
 
-    /**
-     * Sends the data to the multiplexer
-     *
-     * @param event
-     * @param args
-     */
-    send(event, ...args) {
-        this.multiplexer[event].call(null, ...args);
-    }
-
     /**
      * @param doc {Object}
      * @param safe {Boolean} If this is set to true, it assumes that the object is cleaned
@@ -200,7 +190,7 @@ export default class ObservableCollection {
         }
 
         this.store.set(doc._id, doc);
-        this.send('added', doc._id, doc);
+        this.multiplexer.added(doc._id, doc);
     }
 
     /**
@@ -213,7 +203,7 @@ export default class ObservableCollection {
         this.store.set(docId, doc);
 
         if (doc) {
-            this.send('added', doc._id, doc);
+            this.multiplexer.added(doc._id, doc);
         }
     }
 
@@ -241,7 +231,7 @@ export default class ObservableCollection {
         );
 
         if (!_.isEmpty(changed)) {
-            this.send('changed', docId, changed);
+            this.multiplexer.changed(docId, changed);
         }
     }
 
@@ -263,7 +253,7 @@ export default class ObservableCollection {
 
         var changed = DiffSequence.makeChangedFields(storedDoc, oldDoc);
 
-        this.send('changed', docId, changed);
+        this.multiplexer.changed(docId, changed);
     }
 
     /**
@@ -273,7 +263,7 @@ export default class ObservableCollection {
         const doc = this.store.pop(docId);
         if (doc != null) {
             try {
-                this.send('removed', docId, doc);
+                this.multiplexer.removed(docId, doc);
             } catch (e) {
                 // Supressing `removed non-existent exceptions`
                 if (!isRemovedNonExistent(e)) {