Function message_reader

components/simpleproto/src/lib.rs:47–61

(
    src: &mut (impl AsyncRead + Unpin),
    tx: mpsc::UnboundedSender<T>,
)

}

pub async fn message_reader<T: DeserializeOwned>(
    src: &mut (impl AsyncRead + Unpin),
    tx: mpsc::UnboundedSender<T>,
) -> std::io::Result<()> {
    loop {
        match read_message(src).await {
            Ok(msg) => {
                if tx.send(msg).is_err() {
                    return Ok(());
                }
            }
            Err(err) => return Err(err),
        }
    }
}