Home
last modified time | relevance | path

Searched refs:streaming (Results 1 – 15 of 15) sorted by relevance

/tonic/examples/proto/echo/
H A Decho.proto37 // ServerStreamingEcho is server side streaming.
39 // ClientStreamingEcho is client side streaming.
41 // BidirectionalStreamingEcho is bidi streaming.
/tonic/examples/
H A DCargo.toml179 name = "streaming-client"
180 path = "src/streaming/client.rs"
181 required-features = ["streaming"]
184 name = "streaming-server"
185 path = "src/streaming/server.rs"
186 required-features = ["streaming"]
259 streaming = ["dep:tokio-stream", "dep:h2"]
271 …", "reflection", "autoreload", "health", "grpc-web", "tracing", "uds", "streaming", "mock", "tower…
H A Drouteguide-tutorial.md69 streaming and client-side streaming.
117 no more messages. As you can see in our example, you specify a server-side streaming method by
129 all and return its response. You specify a client-side streaming method by placing the `stream`
393 #### Server-side streaming RPC
394 Now let's look at one of our streaming RPCs. `list_features` is a server-side streaming RPC, so we
427 #### Client-side streaming RPC
428 Now let's look at something a little more complicated: the client-side streaming method
477 #### Bidirectional streaming RPC
643 #### Server-side streaming RPC
685 #### Client-side streaming RPC
[all …]
/tonic/examples/proto/routeguide/
H A Droute_guide.proto33 // A server-to-client streaming RPC.
41 // A client-to-server streaming RPC.
47 // A Bidirectional streaming RPC.
/tonic/interop/proto/grpc/testing/
H A Dmessages.proto95 // Client-streaming request.
109 // Client-streaming response.
131 // Server-streaming request.
150 // Server-streaming response, as configured by the request and parameters.
H A Dtest.proto16 // of unary/streaming requests/responses.
/tonic/
H A DREADME.md25 - Bi-directional streaming
68 Also serves as an example of both unary and response streaming.
70 …mples`]: Example gRPC implementations showing off tls, load balancing and bi-directional streaming.
H A DCHANGELOG.md149 * **codec:** Cancelled client streaming handling ([#1315](https://github.com/hyperium/tonic/issues/…
330 * **tonic:** fix extensions disappearing during streaming requests ([5c1bb90](https://github.com/hy…
372 * **codec:** Fix streaming reponses w/ many status ([#689](https://github.com/hyperium/tonic/issues…
/tonic/tonic/src/client/
H A Dgrpc.rs242 self.streaming(request, path, codec).await?.into_parts(); in client_streaming()
278 self.streaming(request, path, codec).await in server_streaming()
282 pub async fn streaming<S, M1, M2, C>( in streaming() method
/tonic/tonic-reflection/src/generated/
H A Dgrpc_reflection_v1.rs258 self.inner.streaming(req, path, codec).await in server_reflection_info()
417 let res = grpc.streaming(method, req).await; in call()
H A Dgrpc_reflection_v1alpha.rs258 self.inner.streaming(req, path, codec).await in server_reflection_info()
417 let res = grpc.streaming(method, req).await; in call()
/tonic/tonic/src/server/
H A Dgrpc.rs336 pub async fn streaming<S, B>( in streaming() function
/tonic/tonic-build/src/
H A Dclient.rs340 self.inner.streaming(req, path, codec).await in generate_streaming()
H A Dserver.rs678 let res = grpc.streaming(method, req).await; in generate_streaming()
/tonic/examples/proto/googleapis/google/pubsub/v1/
H A Dpubsub.proto666 // non-streaming pull or send the `ack_id` in a
667 // `StreamingModifyAckDeadlineRequest` if using streaming pull.
1064 // Request for the `StreamingPull` streaming RPC method. This request is used to
1094 // the message is immediately made available for another streaming or
1095 // non-streaming pull request. If the value is < 0 (an error), the stream will
1123 // streaming pull client that have not yet been acked or nacked, the server
1134 // to the streaming pull client that have not yet been acked or nacked, the