pub async fn decode_from_hyper_stream<T, S, B>(stream: S) -> Result<T>where T: Decode, S: StreamExt<Item = Result<B::Data, B::Error>> + Unpin, B: Body + Unpin,