Starting to upgrade to tokio 0.3

Author: sunjay

Cargo.toml

@@ -59,14 +59,13 @@ features = [
 ]
 
 [dependencies.tokio]
-version = "0.2"
+version = "0.3"
 default-features = false
 features = [
   "process",
   "io-std",
   "io-util",
-  "rt-threaded",
-  "blocking",
+  "rt-multi-thread",
   "sync",
   "stream",
   "time",

src/async_turtle.rs

@@ -98,7 +98,7 @@ impl AsyncTurtle {
             return;
         }
 
-        time::delay_for(time::Duration::from_millis((secs * 1000.0) as u64)).await
+        time::sleep(time::Duration::from_millis((secs * 1000.0) as u64)).await
     }
 
     pub async fn arc_left(&mut self, radius: Distance, extent: Angle) {

src/ipc_protocol/async_ipc_receiver.rs

@@ -30,7 +30,7 @@ impl<T: Serialize + DeserializeOwned + Send + 'static> AsyncIpcReceiver<T> {
                 // disconnected. This allows callers of `recv` to detect the disconnection.
                 let next_value = ipc_receiver.recv();
 
-                let value_sender: oneshot::Sender<_> = match handle.block_on(receiver.recv()) {
+                let value_sender: oneshot::Sender<_> = match receiver.blocking_recv() {
                     Some(value_sender) => value_sender,
                     // The sender for this channel only drops when the main thread has stopped,
                     // so it's pretty safe to stop here

src/renderer_server/animation.rs

@@ -483,7 +483,7 @@ async fn animation_loop(
             },
 
             // Trigger an update once the next update time has elapsed
-            _ = time::delay_until(next_update) => {
+            _ = time::sleep_until(next_update) => {
                 let now = time::Instant::now();
 
                 handle_handler_result(update_animations(