length-prefixed-stream - npm Package Compare versions

Comparing version 1.5.1 to 1.5.2

benchmark.js

 var stream = require('readable-stream')
 var encode = require('./encode')
 var decode = require('./decode')
+var bufferAlloc = require('buffer-alloc')
 
-var buf = new Buffer(32 * 1024)
+var buf = bufferAlloc(32 * 1024)
 var source = new stream.Readable()
@@ -7,0 +8,0 @@ var sent = 0

decode.js

 var varint = require('varint')
 var stream = require('readable-stream')
 var util = require('util')
+var bufferAlloc = require('buffer-alloc-unsafe')
 
@@ -13,3 +14,3 @@ var Decoder = function (opts) {
   this._allowEmpty = !!(opts && opts.allowEmpty)
-  this._prefix = new Buffer(this._limit ? varint.encodingLength(this._limit) : 100)
+  this._prefix = bufferAlloc(this._limit ? varint.encodingLength(this._limit) : 100)
   this._ptr = 0
@@ -39,3 +40,3 @@
       if (this._limit && this._missing > this._limit) return this._prefixError(data)
-      if (!this._missing && this._allowEmpty) this._push(Buffer(0))
+      if (!this._missing && this._allowEmpty) this._push(bufferAlloc(0))
       this._ptr = 0
@@ -62,3 +63,3 @@ return offset + 1
     }
-    this._message = new Buffer(missing)
+    this._message = bufferAlloc(missing)
   }
@@ -65,0 +66,0 @@

encode.js

 var varint = require('varint')
 var stream = require('readable-stream')
 var util = require('util')
+var bufferAlloc = require('buffer-alloc-unsafe')
 
-var pool = new Buffer(10 * 1024)
+var pool = bufferAlloc(10 * 1024)
 var used = 0
@@ -23,3 +24,3 @@
   if (pool.length - used < 100) {
-    pool = new Buffer(10 * 1024)
+    pool = bufferAlloc(10 * 1024)
     used = 0
@@ -26,0 +27,0 @@ }

package.json

 {
   "name": "length-prefixed-stream",
-  "version": "1.5.1",
+  "version": "1.5.2",
   "description": "Streaming length prefixed buffers",
   "main": "index.js",
   "dependencies": {
+    "buffer-alloc-unsafe": "^1.0.0",
     "readable-stream": "^2.0.0",
@@ -11,2 +12,3 @@ "varint": "^5.0.0"
   "devDependencies": {
+    "buffer-from": "^1.0.0",
     "concat-stream": "^1.4.6",
@@ -13,0 +15,0 @@ "from2": "^2.1.0",

test.js

@@ -6,2 +6,4 @@ var tape = require('tape')
 var lpstream = require('./')
+var bufferAlloc = require('buffer-alloc-unsafe')
+var bufferFrom = require('buffer-from')
 
@@ -74,3 +76,3 @@ var chunk = function (ultra) {
   for (var i = 0; i < 50; i++) {
-    expects.push(new Buffer(50))
+    expects.push(bufferAlloc(50))
   }
@@ -127,3 +129,3 @@
   for (var i = 0; i < 50; i++) {
-    expects.push(new Buffer(50))
+    expects.push(bufferAlloc(50))
   }
@@ -180,3 +182,3 @@
   for (var i = 0; i < 50; i++) {
-    expects.push(new Buffer(50))
+    expects.push(bufferAlloc(50))
   }
@@ -203,3 +205,3 @@
   for (var i = 0; i < 5; i++) {
-    expects.push(new Buffer(64 * 1024))
+    expects.push(bufferAlloc(64 * 1024))
   }
@@ -222,3 +224,3 @@
   var i = 0
-  var buf = new Buffer(64 * 1024)
+  var buf = bufferAlloc(64 * 1024)
   var e = lpstream.encode()
@@ -252,3 +254,3 @@ var d = lpstream.decode()
 
-  d.write(new Buffer('zzzzzzzzzzzzzz'))
+  d.write(bufferFrom('zzzzzzzzzzzzzz'))
 })
@@ -265,11 +267,11 @@
     d.on('data', function (data) {
-      t.same(data, Buffer(0), 'empty buffer')
+      t.same(data, bufferAlloc(0), 'empty buffer')
       t.end()
     })
-    d.write(Buffer([0]))
+    d.write(bufferFrom([0]))
     d.end()
   })
 
-  d.write(Buffer([0]))
+  d.write(bufferFrom([0]))
   d.end()
 })

No alert changes

Improved metrics

Total package byte prevSize

12016

increased by2.65%

Lines of code

321

increased by1.58%

Worsened metrics

Dependency count

3

increased by50%

Dev dependency count

6

increased by20%

Number of package files

9

decreased by-10%

Dependency changes

• + Addedbuffer-alloc-unsafe@^1.0.0

• + Addedbuffer-alloc-unsafe@1.1.0(transitive)