rust - 如何在 tokio 中广播流

Question

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

我尝试创建一个广播频道

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

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

Answer 1

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

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