broadcaster

broadcaster为遵循mpsc模式的任何Stream和Sink提供包装器，以实现广播项目。这意味着发送的任何项目都将被每个接收者接收，而不仅仅是第一个检查的接收者（类似于大多数mpmc流）。例如

use broadcaster::BroadcastChannel;
use futures_util::StreamExt;

let mut chan = BroadcastChannel::new();
chan.send(&5i32).await?;
assert_eq!(chan.next().await, Some(5));

let mut chan2 = chan.clone();
chan2.send(&6i32).await?;
assert_eq!(chan.next().await, Some(6));
assert_eq!(chan2.next().await, Some(6));

lib.rs:

broadcaster为遵循mpsc模式的任何Stream和Sink提供包装器，以实现广播项目。这意味着发送的任何项目都将被每个接收者接收，而不仅仅是第一个检查的接收者（类似于大多数mpmc流）。例如

use broadcaster::BroadcastChannel;

use futures_util::StreamExt;

let mut chan = BroadcastChannel::new();
chan.send(&5i32).await?;
assert_eq!(chan.next().await, Some(5));

let mut chan2 = chan.clone();
chan2.send(&6i32).await?;
assert_eq!(chan.next().await, Some(6));
assert_eq!(chan2.next().await, Some(6));