Mi transmisión legible no se detendrá cuando yo lo diga. ¿Que me estoy perdiendo aqui?
Esperaría que la salida se detuviera cada segundo durante un segundo, pero no es así.
const { Readable, Writable } = require('stream'); const r = new Readable({ read() { this.push(Math.random().toString()); } }); const w = new Writable({ write(data, enc, next) { console.log(data.toString()); setTimeout(next, 10) } }); r.pipe(w); setInterval(() => { if(r.isPaused()) { console.log('>>>>>>>>>>> RESUMING') r.resume(); } else { console.log('>>>>>>>>>>> PAUSING') r.pause(); } }, 1000);Al usar pipe/unpipe pude imitar el comportamiento de pausa/reanudar.
const { Readable, Writable } = require('stream'); const r = new Readable({ highWaterMark: 1, read() { const randomNumber = Math.random(); this.push(randomNumber.toString()); } }); const w = new Writable({ highWaterMark: 1, write(randomNumber, enc, next) { console.log(randomNumber.toString()) setTimeout(next, 1000) } }); let isPiped = true; r.pipe(w); setInterval(() => { if(isPiped) { console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>> PAUSE') r.unpipe(w); isPiped = false } else { console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>> RESUME') r.pipe(w); isPiped = true; } }, 10000);