fix: empty streams

.travis.yml

@@ -2,7 +2,7 @@ sudo: false
 language: node_js
 node_js:
   - 8
-  - stable
+  - 10
 
 # Make sure we have new NPM and yarn
 before_install:

src/decode.js

@@ -122,10 +122,6 @@ function readVarintMessage (reader, maxLength, cb) {
         return cb(new Error('size longer than max permitted length of ' + maxLength + '!'))
       }
 
-      if (msgSize <= 0) {
-        return cb(true) // eslint-disable-line standard/no-callback-literal
-      }
-
       readMessage(reader, msgSize, (err, msg) => {
         if (err) {
           return cb(err)

test/fromReader.spec.js

@@ -48,9 +48,8 @@ describe('pull-length-prefixed decodeFromReader', () => {
 
     // decode from reader
     lp.decodeFromReader(reader, function (err, output) {
-      expect(err).to.be.instanceof(Error)
-      expect(output).to.equal(undefined)
-      done()
+      expect(output).to.eql(Buffer.alloc(0))
+      done(err)
     })
   })
 })

test/index.spec.js

@@ -108,15 +108,21 @@ describe('pull-length-prefixed', () => {
         ).to.be.eql([Buffer.alloc(1, 0)])
 
         pull(
-          pull.values(),
+          pull.values([
+            Buffer.alloc(0),
+            Buffer.from('more data')
+          ]),
           lp.encode(),
           lp.decode(),
           pull.collect((err, decoded) => {
             if (err) throw err
 
             expect(
               decoded
-            ).to.be.eql([])
+            ).to.be.eql([
+              Buffer.alloc(0),
+              Buffer.from('more data')
+            ])
 
             done()
           })