From 322f346b97cfc8a621ea5c41fe9c9f97e984ee05 Mon Sep 17 00:00:00 2001 From: Lucio Franco Date: Sat, 21 Sep 2019 11:09:57 -0600 Subject: [PATCH] Use tokio::spawn in routeguide --- tonic-examples/src/routeguide/server.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/tonic-examples/src/routeguide/server.rs b/tonic-examples/src/routeguide/server.rs index 24a4c61..2f3a9e5 100644 --- a/tonic-examples/src/routeguide/server.rs +++ b/tonic-examples/src/routeguide/server.rs @@ -52,19 +52,17 @@ impl server::RouteGuide for RouteGuide { &self, request: Request, ) -> Result, Status> { - use std::thread; - println!("ListFeatures = {:?}", request); let (mut tx, rx) = mpsc::channel(4); let state = self.state.clone(); - thread::spawn(move || { + tokio::spawn(async move { for feature in &state.features[..] { if in_range(feature.location.as_ref().unwrap(), request.get_ref()) { println!(" => send {:?}", feature); - tx.try_send(Ok(feature.clone())).unwrap(); + tx.send(Ok(feature.clone())).await.unwrap(); } }