Home
last modified time | relevance | path

Searched refs:poll_next (Results 1 – 10 of 10) sorted by relevance

/tonic/tonic/src/transport/server/
H A Dincoming.rs88 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
89 let polled = Pin::new(&mut self.inner).poll_next(cx); in poll_next()
H A Dio_stream.rs55 match ready!(self.as_mut().project().inner.poll_next(cx)) { in poll_next_without_tls()
78 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
83 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs122 fn poll_next( in poll_next() method
126 std::pin::Pin::new(&mut self.inner).poll_next(cx) in poll_next()
H A Dv1.rs122 fn poll_next( in poll_next() method
126 std::pin::Pin::new(&mut self.inner).poll_next(cx) in poll_next()
/tonic/tonic/src/codec/
H A Dencode.rs77 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function
94 match source.as_mut().poll_next(cx) { in poll_next()
320 match ready!(self_proj.inner.poll_next(cx)) { in poll_frame()
H A Ddecode.rs330 match future::poll_fn(|cx| Pin::new(&mut *self).poll_next(cx)).await { in message()
389 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
/tonic/tonic/src/transport/channel/service/
H A Ddiscover.rs34 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() method
/tonic/tests/integration_tests/tests/
H A Dstreams.rs52 fn poll_next( in poll_next() method
/tonic/tonic-health/src/
H A Dserver.rs162 fn poll_next( in poll_next() method
167 .poll_next(cx) in poll_next()
/tonic/tonic-web/src/
H A Dcall.rs346 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() function