pub fn body_from_stream<S>(s: S) -> Bodywhere S: Stream<Item = Result<Frame<Bytes>, Error>> + Send + Sync + 'static,