feat: remove length-prefixed-stream dependency

BREAKING: This changes the wire format.

Author: KlausTrainer

index.js

@@ -2,30 +2,25 @@
 
 var pumpify = require('pumpify')
 var through = require('through2')
-var lpStream = require('length-prefixed-stream')
 var msgpack = require('msgpack-lite')
 var snappy = require('snappyjs')
 
 module.exports.createEncodeStream = function SnappyMsgpackEncodeStream (stream) {
-  var msgEncode = through.obj(function (data, enc, next) {
-    next(null, msgpack.encode(data))
-  })
+  var msgEncode = msgpack.createEncodeStream()
 
   var snappyCompress = through.obj(function (data, enc, next) {
     next(null, snappy.compress(data))
   })
 
-  return pumpify.obj(msgEncode, snappyCompress, lpStream.encode())
+  return pumpify.obj(msgEncode, snappyCompress)
 }
 
 module.exports.createDecodeStream = function SnappyMsgpackDecodeStream (stream) {
-  var msgDecode = through.obj(function (data, enc, next) {
-    next(null, msgpack.decode(data))
-  })
+  var msgDecode = msgpack.createDecodeStream()
 
   var snappyUncompress = through.obj(function (data, enc, next) {
     next(null, snappy.uncompress(data))
   })
 
-  return pumpify.obj(lpStream.decode(), snappyUncompress, msgDecode)
+  return pumpify.obj(snappyUncompress, msgDecode)
 }

package.json

@@ -7,7 +7,6 @@
     "semantic-release": "semantic-release pre && npm publish && semantic-release post"
   },
   "dependencies": {
-    "length-prefixed-stream": "^1.5.1",
     "msgpack-lite": "^0.1.26",
     "pumpify": "^1.3.5",
     "snappyjs": "^0.6.0",
@@ -24,7 +23,7 @@
   "license": "MIT",
   "devDependencies": {
     "semantic-release": "^6.3.2",
-    "standard": "^8.0.0",
+    "standard": "^10.0.2",
     "tape": "^4.6.0"
   },
   "repository": {