| /tonic/examples/proto/echo/ |
| H A D | echo.proto | 28 // EchoResponse is the response for echo.
29 message EchoResponse { message
36 rpc UnaryEcho(EchoRequest) returns (EchoResponse) {}
38 rpc ServerStreamingEcho(EchoRequest) returns (stream EchoResponse) {}
40 rpc ClientStreamingEcho(stream EchoRequest) returns (EchoResponse) {}
42 rpc BidirectionalStreamingEcho(stream EchoRequest) returns (stream EchoResponse) {}
|
| /tonic/examples/proto/attrs/ |
| H A D | attrs.proto | 10 // EchoResponse is the response for echo.
11 message EchoResponse { message
18 rpc UnaryEcho(EchoRequest) returns (EchoResponse) {}
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 10 use pb::{EchoRequest, EchoResponse};
13 type ResponseStream = Pin<Box<dyn Stream<Item = Result<EchoResponse, Status>> + Send>>;
40 async fn unary_echo(&self, _: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
54 let repeat = std::iter::repeat(EchoResponse { in server_streaming_echo()
86 ) -> EchoResult<EchoResponse> { in client_streaming_echo() argument
109 .send(Ok(EchoResponse { message: v.message })) in bidirectional_streaming_echo()
|
| /tonic/examples/src/authentication/ |
| H A D | server.rs | 5 use pb::{EchoRequest, EchoResponse};
15 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
17 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/multiplex/ |
| H A D | server.rs | 18 EchoRequest, EchoResponse,
61 ) -> Result<Response<EchoResponse>, Status> { in unary_echo() argument
63 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/load_balance/ |
| H A D | server.rs | 9 use pb::{EchoRequest, EchoResponse};
20 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
23 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | server.rs | 9 use pb::{EchoRequest, EchoResponse};
20 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
23 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/tls/ |
| H A D | server.rs | 5 use pb::{EchoRequest, EchoResponse};
21 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
33 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/proto/unaryecho/ |
| H A D | echo.proto | 28 // EchoResponse is the response for echo.
29 message EchoResponse { message
36 rpc UnaryEcho(EchoRequest) returns (EchoResponse) {}
|
| /tonic/examples/src/tls_client_auth/ |
| H A D | server.rs | 5 use pb::{EchoRequest, EchoResponse};
16 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
24 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/dynamic/ |
| H A D | server.rs | 8 use echo::{EchoRequest, EchoResponse};
25 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
30 Ok(Response::new(EchoResponse { message })) in unary_echo()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 10 use pb::{EchoRequest, EchoResponse};
108 async fn unary_echo(&self, request: Request<EchoRequest>) -> EchoResult<EchoResponse> { in unary_echo() argument
116 Ok(Response::new(EchoResponse { message })) in unary_echo()
|