| /tonic/tests/compression/src/ |
| H A D | util.rs | 47 B: HttpBody<Data = Bytes>,
49 type Data = B::Data; typedef
55 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
102 type Data = T; typedef
108 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tonic/src/ |
| H A D | body.rs | 35 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in new() argument
68 type Data = bytes::Bytes; typedef
74 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 97 type Data = B::Data; typedef
103 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 137 type Data = B::Data; typedef
143 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| H A D | interceptor.rs | 241 type Data = B::Data; typedef
247 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| H A D | router.rs | 145 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 553 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve() argument
574 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_shutdown() argument
597 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming() argument
621 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming_shutdown() argument
643 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_internal() argument
775 B::Data: Send, in serve_connection()
884 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve() argument
907 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_shutdown() argument
991 ResBody: http_body::Body<Data = Bytes> + Send + 'static,
1035 ResBody: http_body::Body<Data = Bytes> + Send + 'static,
[all …]
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 60 type Data = Bytes; typedef
66 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tonic/src/codec/ |
| H A D | encode.rs | 308 type Data = Bytes; typedef
318 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| H A D | prost.rs | 380 type Data = Bytes; typedef
386 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 49 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
208 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_request()
229 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_response()
|
| H A D | call.rs | 164 B::Data: Buf,
255 type Data = Bytes; typedef
261 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 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()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 77 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
|
| H A D | grpc_reflection_v1alpha.rs | 166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
|