add (failing) test for #8

Author: tyrasd

index.js

@@ -19,25 +19,28 @@ function BinarySplit (matcher) {
       buf = bops.join([buffered, buf])
       buffered = undefined
     }
+    console.error(buf, offset)
 
     while (buf) {
       var idx = firstMatch(buf, offset)
       if (idx) {
-        var line = bops.subarray(buf, offset, idx)
         if (idx === buf.length) {
-          buffered = line
+          console.error('idx === buf.length')
+          buffered = buf
           buf = undefined
           offset = idx
         } else {
-          this.push(line)
-          offset = idx + matcher.length
+          console.error('idx !== buf.length')
+          this.push(bops.subarray(buf, 0, idx))
+          buf = bops.subarray(buf, idx)
+          offset = 0
         }
       } else if (idx === 0) {
         buf = bops.subarray(buf, offset + matcher.length)
       } else {
         if (offset >= buf.length) {
           buffered = undefined
-          offset = 0
+          // offset = 0
         } else {
           buffered = buf
         }

test.js

@@ -65,3 +65,15 @@ test('matcher at index 0 check', function (t) {
   splitStream.write(new Buffer('\nhello\nmax'))
   splitStream.end()
 })
+
+test('chunked input', function (t) {
+  fs.createReadStream('test.json')
+  .pipe(split('\n'))
+  .pipe(split('i'))
+  .pipe(splitTest(':', function (err, items) {
+    if (err) throw err
+    console.error('...', err, items)
+    t.equals(items.length, 4)
+    t.end()
+  }))
+})