Searched refs:poll (Results 1 – 11 of 11) sorted by relevance
| /tonic/tonic-web/src/ |
| H A D | client.rs | 95 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
96 let res = ready!(self.project().inner.poll(cx)); in poll()
|
| H A D | service.rs | 161 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
166 let res = ready!(future.poll(cx))?; in poll()
170 CaseProj::Other { future } => future.poll(cx), in poll()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | reconnect.rs | 87 match Pin::new(f).poll(cx) { in poll_ready()
209 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
213 InnerProj::Future(fut) => fut.poll(cx).map_err(Into::into), in poll()
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 80 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
83 if let ready @ Poll::Ready(_) = this.inner.poll(cx) { in poll()
88 ready!(sleep.poll(cx)); in poll()
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 92 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
93 match ready!(self.project().inner.poll(cx)) { in poll()
|
| H A D | router.rs | 173 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
174 match ready!(Pin::new(&mut self.as_mut().0).poll(cx)) { in poll()
|
| H A D | interceptor.rs | 199 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
201 KindProj::Future(future) => future.poll(cx).map_ok(|res| res.map(ResponseBody::wrap)), in poll()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 226 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
228 .poll(cx) in poll()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 84 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 90 let select_output = ready!(pin!(select(&mut projected.inner, tasks)).poll(cx)); in poll_next()
|
| H A D | mod.rs | 1040 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
1044 let response: Response<ResBody> = ready!(this.inner.poll(cx)).map_err(Into::into)?; in poll()
1123 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
1125 Some(fut) => fut.poll(cx).map(|output| { in poll()
|