Module dialectic::backend::mpsc

This is supported on crate feature mpsc only.

A backend implementation using tokio::sync::mpsc channels carrying boxed values Box<dyn Any + Send>, which are downcast to their true type (inferred from the session type) on the other end of the channel.

Structs

SendError

Error returned by the Sender.

Enums

Error	An error thrown while receiving from or sending to a dynamically typed tokio::sync::mpsc channel.
RecvError	An error thrown while receiving from a dynamically typed tokio::sync::mpsc channel.

Functions

channel	Create a bounded mpsc channel for transporting dynamically typed values.
unbounded_channel	Create an unbounded mpsc channel for transporting dynamically typed values.

Type Definitions

Chan	Shorthand for a Chan using a bounded mpsc Sender and Receiver.
Receiver	A bounded receiver for dynamically typed values. See tokio::sync::mpsc::Receiver.
Sender	A bounded sender for dynamically typed values. See tokio::sync::mpsc::Sender.
UnboundedChan	Shorthand for a Chan using an unbounded mpsc UnboundedSender and UnboundedReceiver.
UnboundedReceiver	An unbounded receiver for dynamically typed values. See tokio::sync::mpsc::UnboundedReceiver.
UnboundedSender	An unbounded sender for dynamically typed values. See tokio::sync::mpsc::UnboundedSender.