Node.js：附加到可读流同时通过管道传输到可写流？

Question

我的服务器接收到音频缓冲区的 udp 数据包。 我想将这些传入的块流式传输到 Google 的文本转语音 API。

使用 fs 流，是否有可能以类似的方式实现这一点？：

let stream = fs.createReadStream("empty-file-name").pipe(myOutputStreamToAPI);

dgramserver.on('message', (msg, rinfo) => {
        stream.push(msg)
}

在这个粗略的草图中，我会创建一个空的（可能的？）流，或者在收到第一个数据包时创建流，并随着更多数据包的进入继续推送到流。

这可能吗？

还有什么方法可以实现我想要的结果？也就是说，在将可读流通过管道传输到可写流之后，我希望在不同时间动态添加到可读流中。

这个问题也可以这样问： 如何从动态传入的 udp 数据包中创建可读流？

谢谢

Answer 1

这会给你答案吗

const Stream = require('stream')

const readableStream = new Stream.Readable()
const writableStream = new Stream.Writable()

writableStream._write = (chunk, encoding, next) => {
    console.log(chunk.toString())
    next()
}

readableStream.pipe(writableStream)

readableStream.push('ping!')
readableStream.push('pong!')

writableStream.end()