pub async fn load_stream<S>(stream: S) -> Result<Bytes, Error> where S: Stream<Item = Result<Bytes, Error>> + Unpin,
