pub fn adapt_stream_to_msg_ch(
input: impl Read + Send + 'static,
output: Sender<Vec<u8>>,
) -> JoinHandle<Result<(), String>>Expand description
Read JSON lines from a stream and send them to a channel.
Each line is sent as a separate message. Blocks until the reader is exhausted.