diff options
Diffstat (limited to 'test/parallel/test-stream-unshift-read-race.js')
-rw-r--r-- | test/parallel/test-stream-unshift-read-race.js | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/parallel/test-stream-unshift-read-race.js b/test/parallel/test-stream-unshift-read-race.js index 8239a380def..c21bb60cc61 100644 --- a/test/parallel/test-stream-unshift-read-race.js +++ b/test/parallel/test-stream-unshift-read-race.js @@ -14,7 +14,7 @@ var hwm = 10; var r = stream.Readable({ highWaterMark: hwm }); var chunks = 10; -var data = new Buffer(chunks * hwm + Math.ceil(hwm / 2)); +var data = Buffer.allocUnsafe(chunks * hwm + Math.ceil(hwm / 2)); for (var i = 0; i < data.length; i++) { var c = 'asdf'.charCodeAt(i % 4); data[i] = c; @@ -48,7 +48,7 @@ r._read = function(n) { function pushError() { assert.throws(function() { - r.push(new Buffer(1)); + r.push(Buffer.allocUnsafe(1)); }); } @@ -64,7 +64,7 @@ var ended = false; r.on('end', function() { assert(!ended, 'end emitted more than once'); assert.throws(function() { - r.unshift(new Buffer(1)); + r.unshift(Buffer.allocUnsafe(1)); }); ended = true; w.end(); @@ -75,7 +75,7 @@ r.on('readable', function() { while (null !== (chunk = r.read(10))) { w.write(chunk); if (chunk.length > 4) - r.unshift(new Buffer('1234')); + r.unshift(Buffer.from('1234')); } }); |