如何在 tokio 中广播流

如何解决如何在 tokio 中广播流

我正在尝试构建一个 tokio 流，该流应该将其元素发送到其他两个要并行执行的流。

我尝试用

创建一个广播频道

    let (int_sender,int_receiver) = broadcast::channel(DEFAULT_CHANNEL_CAPACITY);    

然后执行 stream.forward(int_sender)，从 int_receiver 构建另外两个流，但它不起作用，因为 broadcast::Sender 没有实现 Sink（与 {{ 1}})。还有其他选择吗？

解决方法

forward 只是一种将流连接到接收器的便捷方法。您可以使用如下代码手动实现相同的功能：

while let Some(item) = stream.next().await {
    int_sender.send(item)?;
}