pub fn body_stream<B, E>(body: B) -> impl Stream<Item = Result<Bytes, E>>
where B: Body<Data = Bytes>, <B as Body>::Error: Into<E>, E: From<CommonError>,