betterstreams::util
pub fn reader_to_iostream<R: AsyncRead>( reader: R) -> impl Stream<Item = Result<Bytes, Error>>
Converts a struct implementing AsyncRead into a stream of Result<Bytes, io::Error>.
AsyncRead
Result<
Bytes
,
io::Error
>