Sha256: a3de494c833f8e2161a350304886d0882e6bc04a72359872fc902021a29db294
Contents?: true
Size: 974 Bytes
Versions: 5
Compression:
Stored size: 974 Bytes
Contents
'use strict'; require('../common'); var R = require('_stream_readable'); var W = require('_stream_writable'); var assert = require('assert'); var util = require('util'); var ondataCalled = 0; function TestReader() { R.apply(this); this._buffer = Buffer.alloc(100, 'x'); this.on('data', function() { ondataCalled++; }); } util.inherits(TestReader, R); TestReader.prototype._read = function(n) { this.push(this._buffer); this._buffer = Buffer.alloc(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'); });
Version data entries
5 entries across 4 versions & 1 rubygems