Searched defs:Data (Results 1 – 11 of 11) sorted by relevance
| /tonic/tonic/src/ |
| H A D | body.rs | 35 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in new() 68 type Data = bytes::Bytes; typedef 74 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame()
|
| /tonic/tests/compression/src/ |
| H A D | util.rs | 49 type Data = B::Data; typedef 55 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() 102 type Data = T; typedef 108 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame()
|
| /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()
|
| /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()
|
| /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()
|
| 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()
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 553 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve() 574 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_shutdown() 597 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming() 621 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming_shutdown() 643 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_internal() 884 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve() 907 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_shutdown() 935 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming() 966 ResBody: http_body::Body<Data = Bytes> + Send + 'static, in serve_with_incoming_shutdown()
|
| /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()
|
| H A D | prost.rs | 380 type Data = Bytes; typedef 386 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame()
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 206 fn coerce_request<B>(mut req: Request<B>, encoding: Encoding) -> Request<Body> in coerce_request() 227 fn coerce_response<B>(res: Response<B>, encoding: Encoding) -> Response<Body> in coerce_response()
|
| H A D | call.rs | 255 type Data = Bytes; typedef 261 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame()
|