| /tonic/tonic/src/server/ |
| H A D | service.rs | 1 use crate::{Request, Response, Status, Streaming};
77 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
82 T: Service<Request<Streaming<M1>>, Response = Response<M2>, Error = crate::Status>,
87 fn call(&mut self, request: Request<Streaming<M1>>) -> Self::Future { in call()
107 fn call(&mut self, request: Request<Streaming<R>>) -> Self::Future; in call()
112 T: Service<Request<Streaming<M1>>, Response = Response<S>, Error = crate::Status>,
119 fn call(&mut self, request: Request<Streaming<M1>>) -> Self::Future { in call()
|
| H A D | grpc.rs | 8 codec::{Codec, Streaming},
376 let mut stream = pin!(Streaming::new_request( in map_request_unary()
400 ) -> Result<Request<Streaming<T::Decode>>, Status> in map_request_streaming()
408 Streaming::new_request( in map_request_streaming()
|
| /tonic/tests/default_stubs/src/ |
| H A D | lib.rs | 7 use tonic::{Request, Response, Status, Streaming};
32 async fn client_stream(&self, _: Request<Streaming<()>>) -> Result<Response<()>, Status> { in client_stream()
38 _: Request<Streaming<()>>, in bidirectional_stream() argument
|
| /tonic/tests/compression/src/ |
| H A D | lib.rs | 16 Request, Response, Status, Streaming,
78 req: Request<Streaming<SomeData>>, in compress_input_client_stream()
89 req: Request<Streaming<SomeData>>, in compress_output_client_stream()
108 req: Request<Streaming<SomeData>>, in compress_input_output_bidirectional_stream()
|
| H A D | server_stream.rs | 3 use tonic::Streaming;
54 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
112 let mut stream: Streaming<SomeData> = res.into_inner(); in client_disabled_server_enabled()
165 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_disabled()
|
| H A D | bidirectional_stream.rs | 96 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 21 pub struct Streaming<T> { struct
37 impl<T> Unpin for Streaming<T> {} implementation
56 impl<T> Streaming<T> { implementation
300 impl<T> Streaming<T> { impl
386 impl<T> Stream for Streaming<T> { implementation
414 impl<T> fmt::Debug for Streaming<T> { implementation
421 static_assertions::assert_impl_all!(Streaming<()>: Send);
|
| H A D | mod.rs | 18 pub use self::decode::Streaming;
|
| H A D | prost.rs | 154 DecodeBuf, Decoder, EncodeBody, EncodeBuf, Encoder, Streaming, HEADER_SIZE,
182 let mut stream = Streaming::new_request(decoder, body, None, None); in decode()
208 let mut stream = Streaming::new_request(decoder, body, None, Some(MAX_MESSAGE_SIZE)); in decode_max_message_size_exceeded()
|
| /tonic/interop/src/ |
| H A D | server.rs | 21 type Streaming<T> = Request<tonic::Streaming<T>>; typedef
88 req: Streaming<StreamingInputCallRequest>, in streaming_input_call()
108 req: Streaming<StreamingOutputCallRequest>, in full_duplex_call()
148 _: Streaming<StreamingOutputCallRequest>, in half_duplex_call()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 7 codec::{Codec, Decoder, Streaming},
268 ) -> Result<Response<Streaming<M2>>, Status> in server_streaming()
287 ) -> Result<Response<Streaming<M2>>, Status> in streaming()
327 ) -> Result<Response<Streaming<M2>>, Status> in create_response()
355 Streaming::new_response( in create_response()
363 Streaming::new_empty(decoder, body) in create_response()
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 8 use tonic::{transport::Server, Request, Response, Status, Streaming};
85 _: Request<Streaming<EchoRequest>>, in client_streaming_echo()
94 req: Request<Streaming<EchoRequest>>, in bidirectional_streaming_echo()
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 4 use tonic::{Request, Response, Status, Streaming};
51 req: Request<Streaming<Input>>, in client_stream()
|
| /tonic/tonic/src/ |
| H A D | lib.rs | 120 pub use codec::Streaming;
|
| /tonic/tonic-reflection/src/server/ |
| H A D | v1alpha.rs | 5 use tonic::{Request, Response, Status, Streaming};
28 req: Request<Streaming<ServerReflectionRequest>>, in server_reflection_info()
|
| H A D | v1.rs | 5 use tonic::{Request, Response, Status, Streaming};
28 req: Request<Streaming<ServerReflectionRequest>>, in server_reflection_info()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 11 use tonic::{codec::DecodeBuf, codec::Decoder, Status, Streaming};
27 let mut stream = Streaming::new_request(decoder, body.clone(), None, None);
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 284 … async fn #name(#self_param, request: tonic::Request<tonic::Streaming<#req_message>>) in generate_trait_methods()
293 … async fn #name(#self_param, request: tonic::Request<tonic::Streaming<#req_message>>) in generate_trait_methods()
325 … async fn #name(#self_param, request: tonic::Request<tonic::Streaming<#req_message>>) in generate_trait_methods()
343 … async fn #name(#self_param, request: tonic::Request<tonic::Streaming<#req_message>>) in generate_trait_methods()
588 … fn call(&mut self, request: tonic::Request<tonic::Streaming<#request>>) -> Self::Future { in generate_client_streaming()
656 … fn call(&mut self, request: tonic::Request<tonic::Streaming<#request>>) -> Self::Future { in generate_streaming()
|
| H A D | client.rs | 270 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_server_streaming()
332 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_streaming()
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 66 request: Request<tonic::Streaming<Point>>, in record_route()
108 request: Request<tonic::Streaming<RouteNote>>, in route_chat()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 10 use tonic::{Response, Streaming};
159 async fn stream<T>(r: Response<Streaming<T>>) -> Vec<T> { in stream()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 235 tonic::Response<tonic::codec::Streaming<super::ServerReflectionResponse>>, in server_reflection_info()
288 request: tonic::Request<tonic::Streaming<super::ServerReflectionRequest>>, in server_reflection_info()
386 tonic::Streaming<super::ServerReflectionRequest>, in call()
|
| H A D | grpc_reflection_v1alpha.rs | 235 tonic::Response<tonic::codec::Streaming<super::ServerReflectionResponse>>, in server_reflection_info()
288 request: tonic::Request<tonic::Streaming<super::ServerReflectionRequest>>, in server_reflection_info()
386 tonic::Streaming<super::ServerReflectionRequest>, in call()
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 289 _request: Request<tonic::Streaming<Point>>,
298 _request: Request<tonic::Streaming<RouteNote>>,
431 `tonic::Request<tonic::Streaming<Point>>`.
441 request: Request<tonic::Streaming<Point>>,
492 request: Request<tonic::Streaming<RouteNote>>,
681 We use the `message()` method from the `tonic::Streaming` struct to repeatedly read in the
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 183 tonic::Response<tonic::codec::Streaming<super::HealthCheckResponse>>, in watch()
|