Function capnp_futures::write_queue

source ·
pub fn write_queue<W, M>(
    writer: W
) -> (Sender<M>, impl Future<Output = Result<(), Error>>)
where W: AsyncWrite + Unpin, M: AsOutputSegments,
Expand description

Creates a new write queue that wraps the given AsyncWrite.