const EE = require('events').EventEmitter const eos = require('end-of-stream') const ee = new EE() ee.readable = ee.writable = true eos(ee, er => { if (er) throw er console.log('stream ended') }) ee.emit('finish') ee.emit('close') ee.emit('end')