Removed collectFirst. We can pass a function to collect to determine the position of the collector in queue. Filter must be assigned once collector is created.

Author: Josema

.npmignore

@@ -15,4 +15,7 @@ npm-debug.log*
 .grunt
 
 # Files
-test*.*
+src/
+test/
+examples/
+test*.*

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dop",
-  "version": "0.22.4",
+  "version": "0.22.5",
   "main": "./dist/dop.nodejs.js",
   "browser": "./dist/dop.js",
   "unpkg": "./dist/dop.min.js",

src/api/collect.js

@@ -1,5 +1,6 @@
 
-dop.collect = function(filter) {
-    dop.util.invariant(arguments.length===0 || (arguments.length>0 && isFunction(filter)), 'dop.collect only accept one argument as function');
-    return dop.core.createCollector(dop.data.collectors, dop.data.collectors.length, filter);
+dop.collect = function(indexFunction) {
+    dop.util.invariant(arguments.length==0 || (arguments.length==1 && isFunction(indexFunction)), 'dop.collect only accept one argument as function');
+    var index = indexFunction ? indexFunction(dop.data.collectors) : dop.data.collectors.length;
+    return dop.core.createCollector(dop.data.collectors, index);
 };

src/api/collectFirst.js

@@ -1,5 +1,5 @@
 
-dop.core.collector = function(queue, index) {
+dop.core.collector = function Collector(queue, index) {
     this.active = true;
     this.mutations = [];
     this.queue = queue;

src/core/constructors/collector.js

@@ -1,5 +1,5 @@
 
-dop.core.listener = function(args) {
+dop.core.listener = function Listener(args) {
     // Inherit emitter
     dop.util.merge(this, new dop.util.emitter);
     args.unshift(dop, this);

src/core/constructors/listener.js

@@ -1,5 +1,5 @@
 
-dop.core.node = function() {
+dop.core.node = function Node() {
     // Inherit emitter
     dop.util.merge(this, new dop.util.emitter); //https://jsperf.com/inheritance-call-vs-object-assign
     this.connected = false;

src/core/constructors/node.js

@@ -1,5 +1,5 @@
 
-dop.core.observer = function(callback, id) {
+dop.core.observer = function Observer(callback, id) {
     this.callback = callback;
     this.id = id;
     this.observers = {}; // need it for destroy()

src/core/constructors/observer.js

@@ -1,5 +1,5 @@
 
-dop.core.snapshot = function (mutations) {
+dop.core.snapshot = function Snapshot(mutations) {
     this.mutations = mutations;
     this.forward = true;
 };

src/core/constructors/snapshot.js

@@ -1,6 +1,5 @@
 
-dop.core.createCollector = function(queue, index, filter) {
+dop.core.createCollector = function(queue, index) {
     var collector = new dop.core.collector(queue, index);
-    collector.filter = filter;
     return collector;
 };