1c1af81ea0
These properties were initially used to determine stream status back in node v0.8 and earlier. Since streams2 however, these properties were *always* true, which can be misleading for example if you are trying to immediately determine whether a Writable stream is still writable or not (to avoid a "write after end" exception). PR-URL: https://github.com/nodejs/node/pull/4083 Reviewed-By: Chris Dickinson <christopher.s.dickinson@gmail.com>
54 lines
1 KiB
JavaScript
54 lines
1 KiB
JavaScript
'use strict';
|
|
var common = require('../common');
|
|
var R = require('_stream_readable');
|
|
var W = require('_stream_writable');
|
|
var assert = require('assert');
|
|
|
|
var util = require('util');
|
|
var EE = require('events').EventEmitter;
|
|
|
|
var ondataCalled = 0;
|
|
|
|
function TestReader() {
|
|
R.apply(this);
|
|
this._buffer = new Buffer(100);
|
|
this._buffer.fill('x');
|
|
|
|
this.on('data', function() {
|
|
ondataCalled++;
|
|
});
|
|
}
|
|
|
|
util.inherits(TestReader, R);
|
|
|
|
TestReader.prototype._read = function(n) {
|
|
this.push(this._buffer);
|
|
this._buffer = new Buffer(0);
|
|
};
|
|
|
|
var reader = new TestReader();
|
|
setImmediate(function() {
|
|
assert.equal(ondataCalled, 1);
|
|
console.log('ok');
|
|
reader.push(null);
|
|
});
|
|
|
|
function TestWriter() {
|
|
W.apply(this);
|
|
this.write('foo');
|
|
this.end();
|
|
}
|
|
|
|
util.inherits(TestWriter, W);
|
|
|
|
TestWriter.prototype._write = function(chunk, enc, cb) {
|
|
cb();
|
|
};
|
|
|
|
var writer = new TestWriter();
|
|
|
|
process.on('exit', function() {
|
|
assert.strictEqual(reader.readable, false);
|
|
assert.strictEqual(writer.writable, false);
|
|
console.log('ok');
|
|
});
|