Module jormungandr::utils::async_msg

Multiple producer, single-consumer in-memory FIFO channels with asynchronous reading.

Structs

• MessageBox
  The output end of an in-memory FIFO channel.
• MessageQueue
  The input end of an in-memory FIFO channel. This can be read asynchronously in a Tokio task using its Stream implementation.
• SendError
  The error type for Senders used as Sinks.
• TrySendError
  The error type returned from try_send.

Functions

• channel
  Constructs an in-memory channel and returns the output and input halves. The parameter specifies the number of messages that are allowed to be pending in the channel.