Home
last modified time | relevance | path

Searched refs:Output (Results 1 – 25 of 42) sorted by relevance

12

/tonic/tests/web/proto/
H A Dtest.proto6 rpc UnaryCall(Input) returns (Output);
7 rpc ServerStream(Input) returns (stream Output);
8 rpc ClientStream(stream Input) returns (Output);
16 message Output { message
/tonic/tests/web/src/
H A Dlib.rs6 use pb::{test_server::Test, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
24 Ok(Response::new(Output { in unary_call()
31 type ServerStreamStream = BoxStream<Output>;
41 Ok(Output { in server_stream()
52 ) -> Result<Response<Output>, Status> { in client_stream() argument
53 let out = Output { in client_stream()
/tonic/tests/skip_debug/proto/
H A Dtest.proto6 rpc Rpc(Input) returns (Output);
11 message Output {} message
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs4 use integration_tests::pb::{test_server, Input, Output};
19 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in complex_tower_layers_work() argument
80 F: Future<Output = Result<http::Response<B>, E>>,
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() argument
H A Dconnect_info.rs1 use integration_tests::pb::{test_client, test_server, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in getting_connect_info() argument
23 Ok(Response::new(Output {})) in getting_connect_info()
76 use integration_tests::pb::{test_client, test_server, Input, Output};
82 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
92 Ok(Response::new(Output {})) in unary_call()
H A Duser_agent.rs1 use integration_tests::pb::{test_client, test_server, Input, Output};
15 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in writes_user_agent_header() argument
17 Some(_) => Ok(Response::new(Output {})), in writes_user_agent_header()
H A Dinterceptor.rs1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
17 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in interceptor_retrieves_grpc_method() argument
18 Ok(Response::new(Output {})) in interceptor_retrieves_grpc_method()
H A Dclient_layer.rs2 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in connect_supports_standard_tower_layers() argument
20 Some(_) => Ok(Response::new(Output {})), in connect_supports_standard_tower_layers()
H A Dextensions.rs2 pb::{test_client, test_server, Input, Output},
27 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_interceptor() argument
31 Ok(Response::new(Output {})) in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower() argument
81 Ok(Response::new(Output {})) in setting_extension_from_tower()
H A Dhttp2_keep_alive.rs5 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
13 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
14 Ok(Response::new(Output {})) in unary_call()
H A Dtimeout.rs1 use integration_tests::pb::{test_client, test_server, Input, Output};
71 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in run_service_in_background() argument
73 Ok(Response::new(Output {})) in run_service_in_background()
H A Dorigin.rs2 use integration_tests::pb::{test_server, Input, Output};
25 ) -> Result<Response<Output>, Status> { in writes_origin_header() argument
26 Ok(Response::new(Output {})) in writes_origin_header()
H A Droutes_builder.rs7 test1_client, test1_server, test_client, test_server, Input, Input1, Output, Output1,
23 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in multiple_service_using_routes_builder() argument
24 Ok(Response::new(Output {})) in multiple_service_using_routes_builder()
H A Dhttp2_max_header_list_size.rs3 use integration_tests::pb::{test_client, test_server, Input, Output};
25 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in test_http_max_header_list_size_and_long_errors() argument
H A Dconnection.rs1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
14 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
18 Ok(Response::new(Output {})) in unary_call()
/tonic/tests/integration_tests/proto/
H A Dtest.proto6 rpc UnaryCall(Input) returns (Output);
10 message Output {} message
/tonic/tonic/src/server/
H A Dservice.rs15 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
45 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
74 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
104 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
/tonic/tests/web/tests/
H A Dgrpc_web.rs17 use test_web::pb::{test_server::TestServer, Input, Output};
36 let expected = Output { in binary_request()
59 let expected = Output { in text_request()
138 async fn decode_body(body: Incoming, content_type: &str) -> (Output, Bytes) { in decode_body() argument
150 let msg = Output::decode(&mut body.split_to(len as usize)).expect("decode"); in decode_body()
/tonic/tonic-web/src/
H A Dclient.rs91 F: Future<Output = Result<Response<B>, E>>,
93 type Output = Result<Response<GrpcWebCall<B>>, E>; typedef
95 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() argument
/tonic/tests/skip_debug/src/
H A Dlib.rs6 impl std::fmt::Debug for Output { implementation
/tonic/examples/src/cancellation/
H A Dserver.rs54 FRequest: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler() argument
55 FCancellation: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler() argument
/tonic/tonic/src/service/
H A Drecover_error.rs87 F: Future<Output = Result<Response<ResBody>, E>>,
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() argument
/tonic/tonic/src/transport/channel/
H A Dmod.rs38 type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
140 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in balance_channel_with_executor() argument
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() argument
/tonic/tonic/src/transport/channel/service/
H A Dexecutor.rs29 F: Future<Output = ()> + Send + 'static,
/tonic/tonic/src/
H A Dcodegen.rs19 pub type BoxFuture<T, E> = self::Pin<Box<dyn self::Future<Output = Result<T, E>> + Send + 'static>>;

12