| /tonic/tests/compression/src/ |
| H A D | server_stream.rs | 54 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled() localVariable
112 let mut stream: Streaming<SomeData> = res.into_inner(); in client_disabled_server_enabled() localVariable
165 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_disabled() localVariable
|
| H A D | lib.rs | 70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream() localVariable
80 let mut stream = req.into_inner(); in compress_input_client_stream() localVariable
91 let mut stream = req.into_inner(); in compress_output_client_stream() localVariable
110 let mut stream = req.into_inner(); in compress_input_output_bidirectional_stream() localVariable
116 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_input_output_bidirectional_stream() localVariable
|
| H A D | bidirectional_stream.rs | 80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled() localVariable
96 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled() localVariable
|
| H A D | client_stream.rs | 69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled() localVariable
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled() localVariable
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled() localVariable
|
| H A D | compressing_response.rs | 418 let mut stream: Streaming<SomeData> = res.into_inner(); in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable
|
| /tonic/interop/src/ |
| H A D | server.rs | 72 let stream = try_stream! { in streaming_output_call() localVariable
90 let mut stream = req.into_inner(); in streaming_input_call() localVariable
110 let mut stream = req.into_inner(); in full_duplex_call() localVariable
119 let mut stream = single_message.chain(stream); in full_duplex_call() localVariable
121 let stream = try_stream! { in full_duplex_call() localVariable
139 let stream = tokio_stream::empty(); in full_duplex_call() localVariable
|
| H A D | client.rs | 90 let stream = tokio_stream::iter(requests); in client_streaming() localVariable
210 let stream = tokio_stream::empty(); in empty_stream() localVariable
273 let stream = tokio_stream::once(duplex_req); in status_code_and_message() localVariable
276 let stream = response.into_inner(); in status_code_and_message() localVariable
359 let stream = tokio_stream::once(make_ping_pong_request(0)); in custom_metadata() localVariable
391 let mut stream = response.into_inner(); in custom_metadata() localVariable
|
| /tonic/examples/src/streaming/ |
| H A D | client.rs | 18 let stream = client in streaming_echo() localVariable
27 let mut stream = stream.take(num); in streaming_echo() localVariable
|
| H A D | server.rs | 57 let mut stream = Box::pin(tokio_stream::iter(repeat).throttle(Duration::from_millis(200))); in server_streaming_echo() localVariable
|
| /tonic/tests/integration_tests/proto/ |
| H A D | stream.proto | 3 package stream; package
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 239 let mut stream = TokenStream::new(); in generate_trait_methods() localVariable
307 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods() localVariable
332 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods() localVariable
377 let mut stream = TokenStream::new(); in generate_methods() localVariable
509 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_server_streaming() localVariable
634 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_streaming() localVariable
|
| H A D | lib.rs | 250 let mut stream = TokenStream::new(); in generate_deprecated() localVariable
275 let mut stream = TokenStream::new(); in generate_doc_comment() localVariable
283 let mut stream = TokenStream::new(); in generate_doc_comments() localVariable
|
| H A D | client.rs | 174 let mut stream = TokenStream::new(); in generate_methods() localVariable
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 70 let mut stream = request.into_inner(); in record_route() localVariable
113 let mut stream = request.into_inner(); in route_chat() localVariable
|
| H A D | client.rs | 29 let mut stream = client in print_features() localVariable
|
| /tonic/tests/integration_tests/tests/ |
| H A D | status.rs | 184 let mut stream = client in status_from_server_stream() localVariable
254 let mut stream = client in message_and_then_status_from_server_stream() localVariable
|
| H A D | max_message_size.rs | 141 let stream = tokio_stream::iter(vec![Ok(blob.clone()), Ok(blob.clone())]); in response_stream_limit() localVariable
184 let mut stream = client.stream_call(req).await.unwrap().into_inner(); in response_stream_limit() localVariable
|
| H A D | routes_builder.rs | 47 let stream = tokio_stream::once(Ok(output)); in multiple_service_using_routes_builder() localVariable
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 159 async fn stream<T>(r: Response<Streaming<T>>) -> Vec<T> { in stream() function
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 27 let mut stream = Streaming::new_request(decoder, body.clone(), None, None); localVariable
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 182 let mut stream = Streaming::new_request(decoder, body, None, None); in decode() localVariable
208 let mut stream = Streaming::new_request(decoder, body, None, Some(MAX_MESSAGE_SIZE)); in decode_max_message_size_exceeded() localVariable
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 376 let mut stream = pin!(Streaming::new_request( in map_request_unary() localVariable
|