From e5bbf004d351f9829c192f792db7311ef88ab8ce Mon Sep 17 00:00:00 2001 From: critiqjo Date: Thu, 5 Jan 2017 20:41:36 +0530 Subject: [PATCH] Update the use of deprecated APIs For stuff that moved from futures::task to futures::executor --- src/reactor/mod.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/reactor/mod.rs b/src/reactor/mod.rs index ee2c5e628..2a2febeba 100644 --- a/src/reactor/mod.rs +++ b/src/reactor/mod.rs @@ -14,7 +14,8 @@ use std::sync::atomic::{AtomicUsize, ATOMIC_USIZE_INIT, Ordering}; use std::time::{Instant, Duration}; use futures::{self, Future, IntoFuture, Async}; -use futures::task::{self, Unpark, Task, Spawn}; +use futures::executor::{self, Spawn, Unpark}; +use futures::task::Task; use mio; use slab::Slab; @@ -208,7 +209,7 @@ impl Core { pub fn run(&mut self, f: F) -> Result where F: Future, { - let mut task = task::spawn(f); + let mut task = executor::spawn(f); let ready = self.future_readiness.clone(); let mut future_fired = true; @@ -510,7 +511,7 @@ impl Inner { mio::PollOpt::level()); let unpark = Arc::new(MySetReadiness(pair.1)); let entry = entry.insert(ScheduledTask { - spawn: Some(task::spawn(future)), + spawn: Some(executor::spawn(future)), wake: unpark, _registration: pair.0, });