Lines Matching defs:stream
27 // will push up the highWaterMark, and cause the stream to read
31 const Readable = require('stream').Readable;
36 const stream = new Readable({ highWaterMark: 2 });
39 stream._read = function(size) {
44 stream.push(null);
46 stream.push(Buffer.allocUnsafe(size));
51 function flow(stream, size, callback) {
53 const chunk = stream.read(size);
56 stream.once('readable', flow.bind(null, stream, size, callback));
64 flow(stream, 5000, function() {
71 assert.strictEqual(stream.readableHighWaterMark, 8192);
73 assert.strictEqual(stream.readableLength, 0);