一个nodejs stream诡异的行为, 猜测和事件循环有关系, 求解释?

Question

当前目录下准备一个test.txt, 写入一些东西, 比如

>It's for test<

分别执行代码:

1. 注释掉延时为 3 ms的代码块, 输出dest.txt, 内容为

>It's for test<

1. 注释掉延时为 2 ms的代码块, 输出dest.txt, 内容为

>It's for test<>It's for test<

以下为代码

const fs = require('fs')const from = fs.createReadStream('test.txt')const to = fs.createWriteStream('dest.txt', {
    flags: 'a'})from.pipe(to, {
    end: false})from.on('end', () => {    console.log('end')
})// setTimeout(() => {//     from.pipe(to)//this won't work, if time >= 3// }, 3)// setTimeout(() => {//     from.pipe(to)//this will work, if time < 3// }, 2)

只触发end事件一次

不同时间延迟, 输出不同, 行为十分诡异, 求解释?

Answer 1

通过I/O读取字符串到缓冲区timers阶段没有callback执行，写入WriteStream，timers阶段检测到callback，执行callback，然鹅ReadStream没数据，pipe没有效果。timers阶段检测到callback，执行callback，ReadStream数据还在，pipe有效果。用process.stdout测试const&nbsp;fs&nbsp;=&nbsp;require('fs')const&nbsp;from&nbsp;=&nbsp;fs.createReadStream('test.txt')from.pipe(process.stdout,&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;end:&nbsp;false})from.on('end',&nbsp;()&nbsp;=>&nbsp;{&nbsp;&nbsp;&nbsp;&nbsp;console.log('end') }) setTimeout(()&nbsp;=>&nbsp;{&nbsp;&nbsp;&nbsp;&nbsp;console.log('timer&nbsp;callback')&nbsp;&nbsp;&nbsp;&nbsp;from.pipe(process.stdout)&nbsp;//this&nbsp;won't&nbsp;work,&nbsp;if&nbsp;time&nbsp;>=&nbsp;3},&nbsp;3)//&nbsp;setTimeout(()&nbsp;=>&nbsp;{//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;console.log('timer&nbsp;callback')//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;from.pipe(process.stdout)&nbsp;//this&nbsp;will&nbsp;work,&nbsp;if&nbsp;time&nbsp;<&nbsp;3//&nbsp;},&nbsp;2)

Answer 2

默认情况下， 在源流发出时stream.end()在目标Writable流上调用，以便目标不再可写。要禁用此默认行为， 可以将该选项作为传递，从而使目标流保持打开状态：reader.pipe(writer,&nbsp;{&nbsp;end:&nbsp;false&nbsp;});上面说的很清楚了，设置false是保持打开状态，不是你理解的可以一直编辑，也是有时间限制的由于Js是异步处理，所有程序同步执行，写入和settimeout也一样，所以当你设置延迟时长高的时候，是没办法注入进去的。谢谢