| 12345678910111213141516 | const tee = require('./')const { Readable } = require('streamx')const s = new Readable()for (let i = 0; i < 1000; i++) {  s.push(Buffer.alloc(1024))}const [a, b] = tee(s)a.on('data', console.log)setTimeout(function () {  b.read()}, 1000)
 |