1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47
use super::Transport; use http::Request; pub struct HyperTransport<C = ::hyper::client::HttpConnector, B = ::hyper::body::Body>( hyper::Client<C, B>, ); impl<C, B> HyperTransport<C, B> { pub fn new(client: hyper::Client<C, B>) -> Self { Self(client) } pub fn into_inner(self) -> hyper::Client<C, B> { self.0 } } impl<C, B> Into<HyperTransport<C, B>> for hyper::Client<C, B> { fn into(self) -> HyperTransport<C, B> { HyperTransport(self) } } impl Default for HyperTransport<::hyper::client::HttpConnector, ::hyper::body::Body> { fn default() -> Self { Self(hyper::Client::new()) } } impl<C, B> Transport for HyperTransport<C, B> where C: hyper::client::connect::Connect + Clone + Send + Sync + 'static, B: hyper::body::HttpBody + Send + 'static + From<Vec<u8>>, B::Data: Send, B::Error: Into<Box<dyn std::error::Error + Send + Sync>>, { type Error = hyper::error::Error; type Output = hyper::client::ResponseFuture; type Body = hyper::body::Body; type Chunk = hyper::body::Bytes; fn roundtrip(&self, request: Request<Vec<u8>>) -> Self::Output { let (parts, body) = request.into_parts(); let request = hyper::Request::from_parts(parts, body.into()); self.0.request(request) } }