Module circ_sender 

Implements a sender and a Stream type for sending messages from a channel to a circuit, prioritizing the delivery of DESTROY messages.

CircuitRxSender and CircuitRxReceiver take any channel message, because the receiving end can be either a client or a relay circuit reactor. The reactor itself will convert into its restricted message set.

Structs

CircuitRxReceiver 🔒

The receiving end of the SPSC queue for inbound data on its way from channel to circuit

CircuitRxReceiverInner 🔒

The inner state of a CircuitRxReceiver.

CircuitRxSender 🔒

The sending end of the SPSC queue for inbound data on its way from channel to circuit

CircuitRxSenderInner 🔒

The inner state of a CircuitRxSender.

Enums

SendError 🔒

Error returned when trying to write to a CircuitRxSender

Functions

channel 🔒

Wrap the sender and receiver of an mq_queue channel into CircuitRxSender and CircuitRxReceiver.