Function message_writer

components/simpleproto/src/lib.rs:36–45

(
    dst: &mut (impl AsyncWrite + Unpin),
    mut rx: mpsc::UnboundedReceiver<T>,
)

}

pub async fn message_writer<T: Serialize>(
    dst: &mut (impl AsyncWrite + Unpin),
    mut rx: mpsc::UnboundedReceiver<T>,
) -> std::io::Result<()> {
    while let Some(next) = rx.recv().await {
        write_message(&next, dst).await?
    }

    Ok(())
}

pub async fn message_reader<T: DeserializeOwned>(
    src: &mut (impl AsyncRead + Unpin),