| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 7 task::{ready, Context, Poll},
83 if let ready @ Poll::Ready(_) = this.inner.poll(cx) { in poll()
84 return ready.map_err(Into::into); in poll()
88 ready!(sleep.poll(cx)); in poll()
|
| /tonic/tests/compression/src/ |
| H A D | util.rs | 13 task::{ready, Context, Poll},
58 match ready!(this.inner.poll_frame(cx)) { in poll_frame()
109 let frame = ready!(self.project().rx.poll_recv(cx)); in poll_frame()
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 7 use std::task::{ready, Context, Poll};
96 let res = ready!(self.project().inner.poll(cx)); in poll()
|
| H A D | call.rs | 3 use std::task::{ready, Context, Poll};
182 match ready!(this.inner.poll_frame(cx)) { in poll_decode()
222 match ready!(this.inner.poll_frame(cx)) { in poll_encode()
266 match ready!(me.as_mut().poll_decode(cx)) { in poll_frame()
|
| H A D | service.rs | 4 use std::task::{ready, Context, Poll};
166 let res = ready!(future.poll(cx))?; in poll()
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 45 pub async fn ready(&mut self) -> Result<(), tonic::Status> { in ready() function
46 self.inner.ready().await.map_err(|e| { in ready()
58 self.ready().await?; in say_hello()
|
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 7 task::{ready, Context, Poll},
55 match ready!(self.as_mut().project().inner.poll_next(cx)) { in poll_next_without_tls()
90 let select_output = ready!(pin!(select(&mut projected.inner, tasks)).poll(cx)); in poll_next()
|
| H A D | mod.rs | 61 task::{ready, Context, Poll},
1044 let response: Response<ResBody> = ready!(this.inner.poll(cx)).map_err(Into::into)?; in poll()
1104 future::ready(Ok(svc)) in call()
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 7 task::{ready, Context, Poll},
93 match ready!(self.project().inner.poll(cx)) { in poll()
|
| H A D | router.rs | 8 task::{ready, Context, Poll},
174 match ready!(Pin::new(&mut self.as_mut().0).poll(cx)) { in poll()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 240 self.inner.ready().await.map_err(|e| { in generate_unary()
271 self.inner.ready().await.map_err(|e| { in generate_server_streaming()
302 self.inner.ready().await.map_err(|e| { in generate_client_streaming()
333 self.inner.ready().await.map_err(|e| { in generate_streaming()
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 11 task::ready,
249 let frame = match ready!(Pin::new(&mut self.body).poll_frame(cx)) { in poll_frame()
402 if ready!(self.inner.poll_frame(cx))?.is_none() { in poll_next()
|
| H A D | encode.rs | 12 task::{ready, Context, Poll},
320 match ready!(self_proj.inner.poll_next(cx)) { in poll_frame()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 148 .ready() in check()
187 .ready() in watch()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 199 pub async fn ready(&mut self) -> Result<(), T::Error> in ready() method
|
| /tonic/examples/ |
| H A D | helloworld-tutorial.md | 3 …p on the pages linked in this paragraph and come back to this tutorial once you feel you are ready!
77 Great! Now our `.proto` file should be complete and ready for use in our application. Here is what …
|
| H A D | routeguide-tutorial.md | 613 Our client is now ready to make service calls. Note that `client` is mutable, this is because it
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 239 .ready() in server_reflection_info()
|
| H A D | grpc_reflection_v1alpha.rs | 239 .ready() in server_reflection_info()
|
| /tonic/ |
| H A D | CHANGELOG.md | 67 * **tonic:** flush accumulated ready messages when status received ([#1756](https://github.com/hype…
127 * **core:** amortize many ready messages into fewer, larger buffers ([#1423](https://github.com/hyp…
462 * **transport:** return Poll::ready until error is consumed ([#536](https://github.com/hyperium/to…
613 * **build:** Remove async ready ([#185](https://github.com/hyperium/tonic/issues/185)) ([97d5363](h…
|