Rust tokio：：sync：：broadcast：：Receiver 不是克隆

发布于08月10日

我有一个这样的 struct :

#[derive(Clone)]
struct Foo {
    ...  // other state
    receiver: tokio::sync::watch::Receiver<T>,
}

但我意识到，为了应用程序的目的，我实际上需要一个tokio::sync::broadcast通道，它本身只实现Sender一半中的Clone，而不是Receiver.所以我不能简单地替换接收器，因为Clone不能推导出来.也许手动Clone实现是答案，但我不确定它会是什么样子.我想它需要一个发信人的账号和一个打到sender.subscriber()的电话.不确定这是不是正确的方法.

如果频道类型更改为广播，我如何才能拥有一个类型Foo，我可以将句柄克隆到每个类型都能够等待接收新消息的位置？

推荐答案

tokio::sync::broadcast中的接收器是通过调用Sender上的subscribe方法来创建的，如module documentation所述:

通过呼叫Sender::subscribe创建新的Receiver个句柄.返回的Receiver将接收在调用subscribe之后发送的值.

不过，您也可以通过在上面呼叫resubscribe来创建新的Receiver.这将:

重新订阅从当前尾部元素开始的频道.

此接收方句柄将接收重新订阅后发送的所有值的克隆.这将不包括当前接收方队列中的元素.

当然，这种方法只适用于T: Clone人.

因此，如果您希望Foo为Clone(并且您愿意接受Receiver文档中提到的限制)，则必须手动实现它:

struct Foo<T> {
    ...  // other state
    receiver: tokio::sync::watch::Receiver<T>,
}

impl<T: Clone> Clone for Foo {
    fn clone(&self) -> Self {
        Self {
            ... // clone other state
            receiver: self.receiver.resubscribe(),
        }
    }
}