以下是我的最小示例,我原本希望可写对象在readable.push(null);
之后发出"Finish",但什么都没有发生.
import { Readable, Writable } from 'stream';
const readable = new Readable();
const writable = new Writable({
write: (data) => {
console.log('write', data.toString());
}
});
writable.on('finish', () => {
console.log('finish');
});
readable.pipe(writable);
readable.push('test');
readable.push(null);
输出:
write test
我还在writable
和返回值.pipe()
上分别try 了end
、close
和complete
,没有任何结果.