You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
|
|
|
|
'use strict';
|
stream: Simplify flowing, passive data listening
Closes #5860
In streams2, there is an "old mode" for compatibility. Once switched
into this mode, there is no going back.
With this change, there is a "flowing mode" and a "paused mode". If you
add a data listener, then this will start the flow of data. However,
hitting the `pause()` method will switch *back* into a non-flowing mode,
where the `read()` method will pull data out.
Every time `read()` returns a data chunk, it also emits a `data` event.
In this way, a passive data listener can be added, and the stream passed
off to some other reader, for use with progress bars and the like.
There is no API change beyond this added flexibility.
12 years ago
|
|
|
var common = require('../common');
|
|
|
|
|
var assert = require('assert');
|
|
|
|
|
|
|
|
|
|
var spawn = require('child_process').spawn;
|
|
|
|
|
var child = spawn(process.execPath, [], {
|
|
|
|
|
env: {
|
|
|
|
|
NODE_DEBUG: process.argv[2]
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
var wanted = child.pid + '\n';
|
|
|
|
|
var found = '';
|
|
|
|
|
|
|
|
|
|
child.stdout.setEncoding('utf8');
|
|
|
|
|
child.stdout.on('data', function(c) {
|
|
|
|
|
found += c;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
child.stderr.setEncoding('utf8');
|
|
|
|
|
child.stderr.on('data', function(c) {
|
|
|
|
|
console.error('> ' + c.trim().split(/\n/).join('\n> '));
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
child.on('close', function(c) {
|
|
|
|
|
assert(!c);
|
|
|
|
|
assert.equal(found, wanted);
|
|
|
|
|
console.log('ok');
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
setTimeout(function() {
|
|
|
|
|
child.stdin.end('console.log(process.pid)');
|
|
|
|
|
});
|
