Module broadcast 

A multi-producer, multi-consumer broadcast queue with receivers that may be located on remote endpoints.

Each sent value is seen by all consumers. The senders must be local, while the receivers can be sent to remote endpoints. Forwarding is supported.

This has similar functionality as tokio::sync::broadcast with the additional ability to work over remote connections.

Structs

Receiver

Receiving-half of the broadcast channel.

ReceiverStream

A wrapper around a broadcast Receiver that implements Stream.

Sender

Sending-half of the broadcast channel.

Enums

RecvError

An error occurred during receiving over a broadcast channel.

SendError

An error occurred during sending over a broadcast channel.

StreamError

An error occurred during receiving over a broadcast channel receiver stream.

TryRecvError

An error occurred during trying to receive over a broadcast channel.

Functions

channel

Create a bounded, multi-producer, multi-consumer channel where each sent value is broadcasted to all active receivers.