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

Version Path
node-compiler-0.9.1 vendor/node/test/parallel/test-stream2-compatibility.js
node-compiler-0.9.0 vendor/node-v7.2.1/test/parallel/test-stream2-compatibility.js
node-compiler-0.8.0 vendor/node-v7.2.0/test/parallel/test-stream2-compatibility.js
node-compiler-0.7.0 vendor/node-v6.9.1/test/parallel/test-stream2-compatibility.js
node-compiler-0.7.0 vendor/node-v7.1.0/test/parallel/test-stream2-compatibility.js