| /tonic/tests/skip_debug/src/ |
| H A D | lib.rs | 6 impl std::fmt::Debug for Output { implementation
|
| /tonic/tests/skip_debug/proto/ |
| H A D | test.proto | 11 message Output {} message
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 54 FRequest: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
55 FCancellation: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
52 ) -> Result<Response<Output>, Status> { in client_stream()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 19 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in complex_tower_layers_work()
82 type Output = Result<http::Response<MyBody<B>>, BoxError>; typedef
84 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| H A D | connect_info.rs | 18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in getting_connect_info()
82 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
|
| H A D | user_agent.rs | 15 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in writes_user_agent_header()
|
| H A D | client_layer.rs | 18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in connect_supports_standard_tower_layers()
|
| H A D | http2_max_header_list_size.rs | 25 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in test_http_max_header_list_size_and_long_errors()
|
| H A D | interceptor.rs | 17 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in interceptor_retrieves_grpc_method()
|
| H A D | extensions.rs | 27 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower()
|
| H A D | http2_keep_alive.rs | 13 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
|
| H A D | connection.rs | 14 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
|
| H A D | timeout.rs | 71 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in run_service_in_background()
|
| H A D | status.rs | 24 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_details()
82 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_metadata()
|
| H A D | routes_builder.rs | 23 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in multiple_service_using_routes_builder()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 103 async fn grpc(accept_h1: bool) -> (impl Future<Output = Result<(), Error>>, String) { in grpc()
114 async fn grpc_web(accept_h1: bool) -> (impl Future<Output = Result<(), Error>>, String) { in grpc_web()
|
| /tonic/tests/web/proto/ |
| H A D | test.proto | 16 message Output { message
|
| /tonic/tests/integration_tests/proto/ |
| H A D | test.proto | 10 message Output {} message
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 93 type Output = Result<Response<GrpcWebCall<B>>, E>; typedef
95 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 140 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in balance_channel_with_executor()
224 type Output = Result<Response<Body>, super::Error>; typedef
226 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | reconnect.rs | 207 type Output = Result<T, crate::BoxError>; typedef
209 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 90 type Output = Result<Response<ResponseBody<ResBody>>, crate::BoxError>; typedef
92 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| H A D | router.rs | 171 type Output = Result<Response<Body>, crate::BoxError>; typedef
173 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 78 type Output = Result<Res, crate::BoxError>; typedef
80 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|