NodeJS流: Readable.pipe()不会立即发送数据

Question

根据我对流的了解，Stream.Readable.pipe()应该在接收到数据后立即对其进行管道传输。

我正在尝试实现我自己的流，但是输出并不像预期的那样。

const { Writable, Readable } = require("stream");

const writable = new Writable();
writable.data = [];
writable._write = (chunk, encoding, next) => {
  writable.data.push(chunk.toString());
  console.log(chunk.toString());
  next();
};

const readable = new Readable({
  read() {},
});

readable.pipe(writable);
readable.push("hi");
writable.write("ho");
writable.write("ho");
console.log(writable.data);

此代码的输出为

ho
ho
[ 'ho', 'ho' ]
hi

后来管道正在往小溪上写。这是什么意思？

Answer 1

您需要写入流，而不是直接调用writable的写方法。

const { Writable, Readable } = require("stream");

const writable = new Writable();
writable.data = [];
writable._write = (chunk, encoding, next) => {
    writable.data.push(chunk.toString());
    next();
};

const readable = new Readable({
    read() { },
});

const stream = readable.pipe(writable);
stream.write("hi");
stream.write("ho");
stream.write("ho");
console.log(writable.data);

//“嗨”，“吼”，“吼”