Searched refs:Incoming (Results 1 – 5 of 5) sorted by relevance
70 use hyper::body::Incoming;82 impl<S> Service<Request<Incoming>> for H2c<S>100 fn call(&mut self, req: hyper::Request<Incoming>) -> Self::Future { in call()
37 use hyper::body::Incoming;50 type Response = http::Response<Incoming>;
93 SelectOutput::Incoming(stream) => { in poll_next()154 Ok(Some(stream)) => SelectOutput::Incoming(stream), in select()178 Incoming(A), enumerator
51 use hyper::{body::Incoming, service::Service as HyperService};742 … hyper_svc = TowerToHyperService::new(req_svc.map_request(|req: Request<Incoming>| req.map(Body::n… in serve_internal()778 S: HyperService<Request<Incoming>, Response = Response<B>> + Clone + Send + 'static, in serve_connection() argument
6 use hyper::body::Incoming;138 async fn decode_body(body: Incoming, content_type: &str) -> (Output, Bytes) { in decode_body() argument