Function dialectic_tokio_mpsc::unbounded_channel[][src]

pub fn unbounded_channel() -> (UnboundedSender, UnboundedReceiver)

Create an unbounded mpsc channel for transporting dynamically typed values.

This is a wrapper around tokio::sync::mpsc::channel::<Box<dyn Any + Send>>. See tokio::sync::mpsc::unbounded_channel.

Examples

let (tx, rx) = dialectic_tokio_mpsc::unbounded_channel();