Function mesh_channel::pipe::pipe

pub fn pipe() -> (ReadPipe, WritePipe)

Creates a new unidirectional pipe, returning a reader and writer.

The resulting pipe has backpressure, so that if the writer tries to write too many bytes before the reader reads them, then calls to futures::AsyncWriteExt::write will block, and calls to [AsyncWrite::poll_write] will return Poll::Pending.