test/parallel/test-stream2-readable-wrap-empty.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

'use strict';
const common = require('../common');

const Readable = require('_stream_readable');
const EE = require('events').EventEmitter;

const oldStream = new EE();
oldStream.pause = function() {};
oldStream.resume = function() {};

const newStream = new Readable().wrap(oldStream);

newStream
  .on('readable', function() {})
  .on('end', common.mustCall(function() {}));

oldStream.emit('end');