Module remoc::rch::broadcast

Available on crate feature rch only.

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.