pub fn create_local_pipe<T>() -> ((UnboundedSender<T>, UnboundedReceiver<T>), (UnboundedSender<T>, UnboundedReceiver<T>))
Expand description
Return a pair of parent/child pipes connected via unbounded tokio mpsc queues.
pub fn create_local_pipe<T>() -> ((UnboundedSender<T>, UnboundedReceiver<T>), (UnboundedSender<T>, UnboundedReceiver<T>))
Return a pair of parent/child pipes connected via unbounded tokio mpsc queues.