mirror of
https://github.com/nodejs/node.git
synced 2025-05-06 11:29:26 +00:00
85ab4a5f12
Several changes:
* Soft-Deprecate Buffer() constructors
* Add `Buffer.from()`, `Buffer.alloc()`, and `Buffer.allocUnsafe()`
* Add `--zero-fill-buffers` command line option
* Add byteOffset and length to `new Buffer(arrayBuffer)` constructor
* buffer.fill('') previously had no effect, now zero-fills
* Update the docs
PR-URL: https://github.com/nodejs/node/pull/4682
Reviewed-By: Сковорода Никита Андреевич <chalkerx@gmail.com>
Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>
53 lines
1.5 KiB
JavaScript
53 lines
1.5 KiB
JavaScript
'use strict';
|
|
require('../common');
|
|
var assert = require('assert');
|
|
var util = require('util');
|
|
var stream = require('stream');
|
|
|
|
var passed = false;
|
|
|
|
function PassThrough() {
|
|
stream.Transform.call(this);
|
|
}
|
|
util.inherits(PassThrough, stream.Transform);
|
|
PassThrough.prototype._transform = function(chunk, encoding, done) {
|
|
this.push(chunk);
|
|
done();
|
|
};
|
|
|
|
function TestStream() {
|
|
stream.Transform.call(this);
|
|
}
|
|
util.inherits(TestStream, stream.Transform);
|
|
TestStream.prototype._transform = function(chunk, encoding, done) {
|
|
if (!passed) {
|
|
// Char 'a' only exists in the last write
|
|
passed = chunk.toString().indexOf('a') >= 0;
|
|
}
|
|
done();
|
|
};
|
|
|
|
var s1 = new PassThrough();
|
|
var s2 = new PassThrough();
|
|
var s3 = new TestStream();
|
|
s1.pipe(s3);
|
|
// Don't let s2 auto close which may close s3
|
|
s2.pipe(s3, {end: false});
|
|
|
|
// We must write a buffer larger than highWaterMark
|
|
var big = Buffer.alloc(s1._writableState.highWaterMark + 1, 'x');
|
|
|
|
// Since big is larger than highWaterMark, it will be buffered internally.
|
|
assert(!s1.write(big));
|
|
// 'tiny' is small enough to pass through internal buffer.
|
|
assert(s2.write('tiny'));
|
|
|
|
// Write some small data in next IO loop, which will never be written to s3
|
|
// Because 'drain' event is not emitted from s1 and s1 is still paused
|
|
setImmediate(s1.write.bind(s1), 'later');
|
|
|
|
// Assert after two IO loops when all operations have been done.
|
|
process.on('exit', function() {
|
|
assert(passed, 'Large buffer is not handled properly by Writable Stream');
|
|
});
|