| /tonic/examples/src/streaming/ |
| H A D | client.rs | 28 while let Some(item) = stream.next().await { in streaming_echo()
44 while let Some(received) = resp_stream.next().await { in bidirectional_streaming_echo()
60 while let Some(received) = resp_stream.next().await { in bidirectional_streaming_echo_throttle()
|
| H A D | server.rs | 63 while let Some(item) = stream.next().await { in server_streaming_echo()
106 while let Some(result) = in_stream.next().await { in bidirectional_streaming_echo()
146 .serve("[::1]:50051".to_socket_addrs().unwrap().next().unwrap()) in main()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 100 .next() in make_v1_request()
108 assert!(inbound.next().await.is_none()); in make_v1_request()
157 .next() in make_v1alpha_request()
165 assert!(inbound.next().await.is_none()); in make_v1alpha_request()
|
| H A D | server.rs | 136 .next() in make_test_reflection_request()
144 assert!(inbound.next().await.is_none()); in make_test_reflection_request()
|
| /tonic/tests/compression/src/ |
| H A D | server_stream.rs | 57 .next() in client_enabled_server_enabled()
64 .next() in client_enabled_server_enabled()
115 .next() in client_disabled_server_enabled()
168 .next() in client_enabled_server_disabled()
|
| H A D | lib.rs | 81 while let Some(item) = stream.next().await { in compress_input_client_stream()
92 while let Some(item) = stream.next().await { in compress_output_client_stream()
111 while let Some(item) = stream.next().await { in compress_input_output_bidirectional_stream()
|
| H A D | bidirectional_stream.rs | 99 .next() in client_enabled_server_enabled()
105 .next() in client_enabled_server_enabled()
|
| H A D | compressing_response.rs | 421 .next() in disabling_compression_on_response_but_keeping_compression_on_stream()
428 .next() in disabling_compression_on_response_but_keeping_compression_on_stream()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 281 .next() in test_service_watch()
307 .next() in test_service_watch()
319 .next() in test_service_watch()
330 .next() in test_service_watch()
338 let item = resp.next().await; in test_service_watch()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | routes_builder.rs | 100 let first = match stream_response.next().await { in multiple_service_using_routes_builder()
106 assert!(stream_response.next().await.is_none()); in multiple_service_using_routes_builder()
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 1238 fn next(&mut self) -> Option<Self::Item> { in next() method
1239 self.inner.next().map(|item| { in next()
1265 fn next(&mut self) -> Option<Self::Item> { in next() method
1266 self.inner.next().map(|item| { in next()
1292 fn next(&mut self) -> Option<Self::Item> { in next() method
1294 .next() in next()
1309 self.inner.next().map(|key| { in next()
1331 self.inner.next().map(|item| { in next()
1352 self.inner.next().map(|item| { in next()
1378 .next() in next()
[all …]
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 76 while let Some(point) = stream.next().await { in record_route()
116 while let Some(note) = stream.next().await { in route_chat()
|
| /tonic/tonic-reflection/src/server/ |
| H A D | v1alpha.rs | 36 while let Some(req) = req_rx.next().await { in server_reflection_info()
|
| H A D | v1.rs | 36 while let Some(req) = req_rx.next().await { in server_reflection_info()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 423 .next() in decode_trailers_frame()
426 .next() in decode_trailers_frame()
431 .next() in decode_trailers_frame()
|
| /tonic/tonic-build/src/ |
| H A D | lib.rs | 322 while let Some(x) = it.next() { in naive_snake_case()
|
| /tonic/interop/src/ |
| H A D | client.rs | 173 match response.next().await { in ping_pong()
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | schema.proto | 203 // system should return the next page of data.
|
| H A D | pubsub.proto | 302 // return the next page of data.
330 // that the system should return the next page of data.
361 // that the system should return the next page of data.
939 // system should return the next page of data.
1258 // should return the next page of data.
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 449 while let Some(point) = stream.next().await {
498 while let Some(note) = stream.next().await {
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 718 io = incoming.next() => { in serve_internal()
|