Home
last modified time | relevance | path

Searched refs:poll_ready (Results 1 – 25 of 32) sorted by relevance

12

/tonic/tonic/src/client/
H A Dservice.rs24 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_ready() method
43 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
44 Service::poll_ready(self, cx) in poll_ready()
/tonic/tonic/src/transport/channel/service/
H A Dconnection.rs109 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
110 Service::poll_ready(&mut self.inner, cx).map_err(Into::into) in poll_ready()
147 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
148 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
185 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
186 self.connector.poll_ready(cx).map_err(Into::into) in poll_ready()
H A Duser_agent.rs37 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
38 self.inner.poll_ready(cx) in poll_ready()
H A Dadd_origin.rs39 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
40 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
H A Dconnector.rs44 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
46 .poll_ready(cx) in poll_ready()
H A Dreconnect.rs62 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
73 match self.mk_service.poll_ready(cx) { in poll_ready()
116 match inner.poll_ready(cx) { in poll_ready()
/tonic/tonic/src/service/
H A Dlayered.rs30 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
31 self.inner.poll_ready(cx) in poll_ready()
H A Drecover_error.rs61 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
62 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
H A Dinterceptor.rs125 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
126 self.inner.poll_ready(cx) in poll_ready()
H A Drouter.rs153 fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
/tonic/examples/src/tower/
H A Dclient.rs66 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
67 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
H A Dserver.rs93 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
94 self.inner.poll_ready(cx) in poll_ready()
/tonic/tonic-web/src/
H A Dclient.rs59 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
60 self.inner.poll_ready(cx) in poll_ready()
H A Dservice.rs56 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
57 self.inner.poll_ready(cx) in poll_ready()
263 fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
/tonic/tests/integration_tests/tests/
H A Dorigin.rs94 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
95 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
H A Dextensions.rs138 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
139 self.inner.poll_ready(cx) in poll_ready()
H A Dcomplex_tower_middleware.rs64 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
/tonic/tonic/src/transport/server/service/
H A Dio.rs58 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
59 self.inner.poll_ready(cx) in poll_ready()
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs116 fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
127 fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
/tonic/tests/compression/src/
H A Dcompressing_response.rs29 fn poll_ready( in client_enabled_server_enabled() function
33 self.service.poll_ready(cx) in client_enabled_server_enabled()
215 fn poll_ready( in client_disabled() function
219 self.0.poll_ready(cx) in client_disabled()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs37 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
38 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
/tonic/tonic/src/transport/channel/
H A Dmod.rs212 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
213 Service::poll_ready(&mut self.svc, cx).map_err(super::Error::from_source) in poll_ready()
/tonic/examples/src/h2c/
H A Dclient.rs55 fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() method
H A Dserver.rs93 fn poll_ready( in poll_ready() function
/tonic/tonic/src/transport/server/
H A Dmod.rs732 poll_fn(|cx| svc.poll_ready(cx)) in serve_internal()
998 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function
999 self.inner.poll_ready(cx).map_err(Into::into) in poll_ready()
1078 fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() function

12