Searched refs:ResponseBody (Results 1 – 9 of 9) sorted by relevance
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 57 type Response = Response<ResponseBody<ResBody>>;
90 type Output = Result<Response<ResponseBody<ResBody>>, crate::BoxError>;
95 let response = response.map(ResponseBody::full); in poll()
101 let res = Response::from_parts(parts, ResponseBody::empty()); in poll()
112 pub struct ResponseBody<B> { struct
117 impl<B> fmt::Debug for ResponseBody<B> { implementation
123 impl<B> ResponseBody<B> { impl
133 impl<B> http_body::Body for ResponseBody<B> implementation
|
| H A D | interceptor.rs | 120 type Response = http::Response<ResponseBody<ResBody>>;
197 type Output = Result<http::Response<ResponseBody<B>>, E>;
201 KindProj::Future(future) => future.poll(cx).map_ok(|res| res.map(ResponseBody::wrap)), in poll()
204 let response = http::Response::from_parts(parts, ResponseBody::<B>::empty()); in poll()
214 pub struct ResponseBody<B> { struct
226 impl<B> ResponseBody<B> { implementation
240 impl<B: http_body::Body> http_body::Body for ResponseBody<B> { implementation
|
| /tonic/tonic/src/client/ |
| H A D | service.rs | 15 type ResponseBody: Body; typedef
19 type Future: Future<Output = Result<http::Response<Self::ResponseBody>, Self::Error>>;
39 type ResponseBody = ResBody; typedef
|
| H A D | grpc.rs | 215 T::ResponseBody: HttpBody + Send + 'static, in unary()
216 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in unary()
234 T::ResponseBody: HttpBody + Send + 'static, in client_streaming()
235 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in client_streaming()
271 T::ResponseBody: HttpBody + Send + 'static, in server_streaming()
272 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in server_streaming()
290 T::ResponseBody: HttpBody + Send + 'static, in streaming()
291 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in streaming()
326 response: http::Response<T::ResponseBody>, in create_response() argument
330 T::ResponseBody: HttpBody + Send + 'static, in create_response()
[all …]
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 35 T::ResponseBody: Body + Send + 'static,
37 <T::ResponseBody as Body>::Error: Into<StdError> + Send,
38 <T::ResponseBody as Body>::Data: Into<bytes::Bytes> + Send,
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 72 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static, in generate_internal()
73 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send, in generate_internal()
88 T::ResponseBody: Default, in generate_internal()
91 … Response = http::Response<<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody> in generate_internal()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 77 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
78 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
94 T::ResponseBody: Default, in with_interceptor()
98 <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody, in with_interceptor()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
167 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
183 T::ResponseBody: Default, in with_interceptor()
187 <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody, in with_interceptor()
|
| H A D | grpc_reflection_v1alpha.rs | 166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
167 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
183 T::ResponseBody: Default, in with_interceptor()
187 <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody, in with_interceptor()
|