Comparing version 0.0.1 to 0.0.2
@@ -28,4 +28,4 @@ #!/usr/bin/env node | ||
var classifier = function(input, cb) { | ||
var index = u.indexOf(partitionRanges, input[partitionByKey]) | ||
var classifier = function(doc, cb) { | ||
var index = u.indexOf(partitionRanges, doc[partitionByKey]) | ||
return cb(null, index) | ||
@@ -32,0 +32,0 @@ } |
{ | ||
"name": "multi-fork", | ||
"version": "0.0.1", | ||
"version": "0.0.2", | ||
"description": "Fork a stream into multiple streams", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -41,4 +41,4 @@ # multi-fork | ||
var classifier = function(input, cb) { | ||
var index = u.indexOf(partitionRanges, input[partitionByKey]) | ||
var classifier = function(doc, cb) { | ||
var index = u.indexOf(partitionRanges, doc[partitionByKey]) | ||
return cb(null, index) | ||
@@ -45,0 +45,0 @@ } |
6385