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
.