Searched refs:fut (Results 1 – 13 of 13) sorted by relevance
31 fn execute(&self, fut: F) { in execute()32 self.inner.execute(Box::pin(fut)) in execute()
81 let fut = self.mk_service.make_service(self.target.clone()); in poll_ready() localVariable82 self.state = State::Connecting(fut); in poll_ready()151 let fut = service.call(request); in call() localVariable152 ResponseFuture::new(fut) in call()213 InnerProj::Future(fut) => fut.poll(cx).map_err(Into::into), in poll()
65 let fut = self.inner.call(request); in call() localVariable67 Box::pin(async move { fut.await.map_err(Into::into) }) in call()
152 let fut = self.inner.send_request(req); in call() localVariable154 Box::pin(async move { fut.await.map_err(Into::into).map(|res| res.map(Body::new)) }) in call()190 let fut = self.connector.call(req); in call() localVariable195 let io = fut.await.map_err(Into::into)?; in call()
468 Box::pin(fut) in generate_unary()477 let fut = async move { in generate_unary() localVariable489 Box::pin(fut) in generate_unary()535 Box::pin(fut) in generate_server_streaming()544 let fut = async move { in generate_server_streaming() localVariable556 Box::pin(fut) in generate_server_streaming()593 Box::pin(fut) in generate_client_streaming()602 let fut = async move { in generate_client_streaming() localVariable614 Box::pin(fut) in generate_client_streaming()661 Box::pin(fut) in generate_streaming()[all …]
346 let fut = async move { in call() localVariable349 Box::pin(fut) in call()357 let fut = async move { in call() localVariable372 Box::pin(fut) in call()392 let fut = async move { in call() localVariable395 Box::pin(fut) in call()403 let fut = async move { in call() localVariable418 Box::pin(fut) in call()
143 let fut = async move { inner.say_hello(request).await }; in call() localVariable144 Box::pin(fut) in call()148 let fut = async move { in call() localVariable155 Box::pin(fut) in call()
106 let fut = Server::builder() in grpc() localVariable111 (fut, url) in grpc()117 let fut = Server::builder() in grpc_web() localVariable123 (fut, url) in grpc_web()
75 let fut = self.inner.call(req); in call() localVariable77 ResponseFuture { inner: fut } in call()
100 let fut = self.inner.call(req); in call() localVariable102 Box::pin(async move { fut.await.map_err(Into::into) }) in call()
390 let fut = async move { in call() localVariable397 Box::pin(fut) in call()405 let fut = async move { in call() localVariable420 Box::pin(fut) in call()
1125 Some(fut) => fut.poll(cx).map(|output| { in poll()