问题描述
输出流表示具有最大长度的接收器。因此,该流将被逐字节读取并流入可写流 1,直到它已满。然后我会切换到流 2 写入下一个字节等等。
┌────────────────────────────────────┐ ┌────────────────────────────────────┐ │ │ ┌─────────────────────┐ │┌──────────┐┌──────────┐┌─────────┐ │ │ someInputStream │──▶│ streamMultiplexer │ ││ stream1 ││ stream2 ││ stream3 │ │ │ │ └─────────────────────┘ │└──────────┘└──────────┘└─────────┘ │ └────────────────────────────────────┘ │ └──────▲───────────▲──────────▲──────┘ │ │ │ │ └───────────────────┴───────────┴──────────┘
@H_404_7@我可能可以手动完成,但我希望找到一些已经提供这种服务的模块的提示。类似于 unix 命令“split”的作用。仅适用于 nodejs 流和管道..
var someInputStream = ...; var = new StreamMultiplexer({ chunkSize: 1000000,writeStreams: [ stream1,stream2,stream3 ] }) someInputStream.pipe(streamMultiplexer);
@H_404_7@解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)