Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 56) sorted by relevance

123

/tonic/tests/compression/proto/
H A Dtest.proto10 rpc CompressOutputServerStream(google.protobuf.Empty) returns (stream SomeData);
11 rpc CompressInputClientStream(stream SomeData) returns (google.protobuf.Empty);
12 rpc CompressOutputClientStream(stream SomeData) returns (SomeData);
13 rpc CompressInputOutputBidirectionalStream(stream SomeData) returns (stream SomeData);
/tonic/tests/compression/src/
H A Dlib.rs70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream() localVariable
73 Ok(self.prepare_response(Response::new(Box::pin(stream)))) in compress_output_server_stream()
80 let mut stream = req.into_inner(); in compress_input_client_stream() localVariable
81 while let Some(item) = stream.next().await { in compress_input_client_stream()
91 let mut stream = req.into_inner(); in compress_output_client_stream() localVariable
92 while let Some(item) = stream.next().await { in compress_output_client_stream()
110 let mut stream = req.into_inner(); in compress_input_output_bidirectional_stream() localVariable
111 while let Some(item) = stream.next().await { in compress_input_output_bidirectional_stream()
116 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_input_output_bidirectional_stream() localVariable
119 Ok(self.prepare_response(Response::new(Box::pin(stream)))) in compress_input_output_bidirectional_stream()
H A Dserver_stream.rs54 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled() localVariable
56 stream in client_enabled_server_enabled()
63 stream in client_enabled_server_enabled()
112 let mut stream: Streaming<SomeData> = res.into_inner(); in client_disabled_server_enabled() localVariable
114 stream in client_disabled_server_enabled()
165 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_disabled() localVariable
167 stream in client_enabled_server_disabled()
H A Dbidirectional_stream.rs80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled() localVariable
81 let req = Request::new(stream); in client_enabled_server_enabled()
96 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled() localVariable
98 stream in client_enabled_server_enabled()
104 stream in client_enabled_server_enabled()
/tonic/tests/default_stubs/proto/
H A Dtest.proto9 rpc ServerStream(google.protobuf.Empty) returns (stream google.protobuf.Empty);
10 rpc ClientStream(stream google.protobuf.Empty) returns (google.protobuf.Empty);
11 rpc BidirectionalStream(stream google.protobuf.Empty) returns (stream google.protobuf.Empty);
H A Dtest_default.proto9 rpc ServerStream(google.protobuf.Empty) returns (stream google.protobuf.Empty);
10 rpc ClientStream(stream google.protobuf.Empty) returns (google.protobuf.Empty);
11 rpc BidirectionalStream(stream google.protobuf.Empty) returns (stream google.protobuf.Empty);
/tonic/interop/src/
H A Dserver.rs72 let stream = try_stream! { in streaming_output_call() localVariable
82 Box::pin(stream) as Self::StreamingOutputCallStream in streaming_output_call()
90 let mut stream = req.into_inner(); in streaming_input_call() localVariable
93 while let Some(msg) = stream.try_next().await? { in streaming_input_call()
110 let mut stream = req.into_inner(); in full_duplex_call() localVariable
112 if let Some(first_msg) = stream.message().await? { in full_duplex_call()
119 let mut stream = single_message.chain(stream); in full_duplex_call() localVariable
121 let stream = try_stream! { in full_duplex_call() localVariable
122 while let Some(msg) = stream.try_next().await? { in full_duplex_call()
137 Ok(Response::new(Box::pin(stream) as Self::FullDuplexCallStream)) in full_duplex_call()
[all …]
H A Dclient.rs90 let stream = tokio_stream::iter(requests); in client_streaming() localVariable
92 let result = client.streaming_input_call(Request::new(stream)).await; in client_streaming()
210 let stream = tokio_stream::empty(); in empty_stream() localVariable
211 let result = client.full_duplex_call(Request::new(stream)).await; in empty_stream()
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
277 let responses = stream.collect::<Vec<_>>().await; in status_code_and_message()
359 let stream = tokio_stream::once(make_ping_pong_request(0)); in custom_metadata() localVariable
360 let mut req_stream = Request::new(stream); in custom_metadata()
391 let mut stream = response.into_inner(); in custom_metadata() localVariable
[all …]
/tonic/tonic-build/src/
H A Dlib.rs250 let mut stream = TokenStream::new(); in generate_deprecated() localVariable
251 stream.append(Punct::new('#', Spacing::Alone)); in generate_deprecated()
252 stream.append(group); in generate_deprecated()
254 stream in generate_deprecated()
275 let mut stream = TokenStream::new(); in generate_doc_comment() localVariable
276 stream.append(Punct::new('#', Spacing::Alone)); in generate_doc_comment()
277 stream.append(group); in generate_doc_comment()
278 stream in generate_doc_comment()
283 let mut stream = TokenStream::new(); in generate_doc_comments() localVariable
286 stream.extend(generate_doc_comment(comment)); in generate_doc_comments()
[all …]
H A Dserver.rs239 let mut stream = TokenStream::new(); in generate_trait_methods() localVariable
307 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods() localVariable
349 stream.extend(method); in generate_trait_methods()
352 stream in generate_trait_methods()
377 let mut stream = TokenStream::new(); in generate_methods() localVariable
429 stream.extend(method); in generate_methods()
432 stream in generate_methods()
509 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_server_streaming() localVariable
510 quote!(type ResponseStream = T::#stream) in generate_server_streaming()
634 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_streaming() localVariable
[all …]
/tonic/tonic/src/transport/server/
H A Dincoming.rs91 if let Poll::Ready(Some(Ok(stream))) = &polled { in poll_next()
92 set_accepted_socket_options(stream, self.nodelay, &self.keepalive); in poll_next()
101 stream: &TcpStream, in set_accepted_socket_options()
106 if let Err(e) = stream.set_nodelay(nodelay) { in set_accepted_socket_options()
112 let sock_ref = socket2::SockRef::from(&stream); in set_accepted_socket_options()
H A Dio_stream.rs93 SelectOutput::Incoming(stream) => { in poll_next()
96 let io = tls.accept(stream).await?; in poll_next()
154 Ok(Some(stream)) => SelectOutput::Incoming(stream), in select()
165 stream = incoming_stream_future => stream, in select()
/tonic/tests/integration_tests/proto/
H A Dstream.proto3 package stream; package
6 rpc StreamCall(InputStream) returns (stream OutputStream);
/tonic/tests/service_named_service/proto/
H A Dfoo.proto6 rpc Foo(stream FooRequest) returns (stream FooResponse) {}
/tonic/tests/same_name/proto/
H A Dfoo.proto6 rpc Foo(stream FooRequest) returns (stream FooResponse) {}
/tonic/examples/src/streaming/
H A Dclient.rs18 let stream = client in streaming_echo() localVariable
27 let mut stream = stream.take(num); in streaming_echo() localVariable
28 while let Some(item) = stream.next().await { in streaming_echo()
/tonic/examples/proto/echo/
H A Decho.proto38 rpc ServerStreamingEcho(EchoRequest) returns (stream EchoResponse) {}
40 rpc ClientStreamingEcho(stream EchoRequest) returns (EchoResponse) {}
42 rpc BidirectionalStreamingEcho(stream EchoRequest) returns (stream EchoResponse) {}
/tonic/tonic-reflection/
H A DCargo.toml26 server = ["dep:prost-types", "dep:tokio", "dep:tokio-stream"]
33 tokio-stream = {version = "0.1", default-features = false, optional = true }
37 tokio-stream = {version = "0.1", default-features = false, features = ["net"]}
56 "futures_core::stream::Stream",
/tonic/tests/web/proto/
H A Dtest.proto7 rpc ServerStream(Input) returns (stream Output);
8 rpc ClientStream(stream Input) returns (Output);
/tonic/interop/proto/grpc/testing/
H A Dtest.proto42 returns (stream StreamingOutputCallResponse);
46 rpc StreamingInputCall(stream StreamingInputCallRequest)
52 rpc FullDuplexCall(stream StreamingOutputCallRequest)
53 returns (stream StreamingOutputCallResponse);
57 // stream of responses are returned to the client when the server starts with
59 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
60 returns (stream StreamingOutputCallResponse);
/tonic/tests/ambiguous_methods/proto/
H A Dambiguous_methods.proto17 rpc Drop (DropReq) returns (stream DropResp);
18 rpc Clone (DropReq) returns (stream DropResp);
/tonic/tests/web/tests/
H A Dgrpc.rs8 use tokio_stream::{self as stream, StreamExt};
36 let input_stream = || stream::iter(vec![input(), input()]); in smoke_client_stream()
64 let r1 = stream(r1).await; in smoke_server_stream()
65 let r2 = stream(r2).await; in smoke_server_stream()
66 let r3 = stream(r3).await; in smoke_server_stream()
67 let r4 = stream(r4).await; in smoke_server_stream()
159 async fn stream<T>(r: Response<Streaming<T>>) -> Vec<T> { in stream() function
/tonic/examples/
H A Drouteguide-tutorial.md146 rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
180 tokio-stream = "0.1"
182 async-stream = "0.2"
443 let mut stream = request.into_inner();
495 let mut stream = request.into_inner();
519 from one (input) stream to another (output) stream. As the input is processed, each value is
526 [async-stream]: https://github.com/tokio-rs/async-stream
665 let mut stream = client
683 no more messages left in the stream.
729 a stream suitable for passing into our service method. The resulting stream is then wrapped in a
[all …]
/tonic/interop/
H A DCargo.toml16 async-stream = "0.3"
26 tokio-stream = "0.1"
/tonic/tests/integration_tests/
H A DCargo.toml17 async-stream = "0.3"
22 tokio-stream = {version = "0.1.5", features = ["net"]}

123