Re-add futures01 to aura and babe tests as a dev-dep

client/consensus/aura/Cargo.toml

@@ -40,3 +40,4 @@ substrate-test-runtime-client = { version = "2.0.0", path = "../../../test-utils
 tokio = "0.1.22"
 env_logger = "0.7.0"
 tempfile = "3.1.0"
+futures01 = { package = "futures", version = "0.1" }

client/consensus/aura/src/lib.rs

@@ -1002,10 +1002,10 @@ mod tests {
 			runtime.spawn(aura);
 		}
 
-		runtime.spawn(futures::future::poll_fn(move |_| {
+		runtime.spawn(futures01::future::poll_fn(move || {
 			net.lock().poll();
-			std::task::Poll::<()>::Pending
-		}).unit_error().compat());
+			Ok::<_, ()>(futures01::Async::NotReady::<()>)
+		}));
 
 		runtime.block_on(future::join_all(import_notifications)
 			.unit_error().compat()).unwrap();

client/consensus/babe/Cargo.toml

@@ -50,6 +50,7 @@ sc-block-builder = { version = "2.0.0", path = "../../block-builder" }
 tokio = "0.1.22"
 env_logger = "0.7.0"
 tempfile = "3.1.0"
+futures01 = { package = "futures", version = "0.1" }
 
 [features]
 test-helpers = []

client/consensus/babe/src/tests.rs

@@ -406,10 +406,10 @@ fn run_one_test(
 		}).expect("Starts babe").unit_error().compat());
 	}
 
-	runtime.spawn(futures::future::poll_fn(move |_| {
+	runtime.spawn(futures01::future::poll_fn(move || {
 		net.lock().poll();
-		std::task::Poll::<()>::Pending
-	}).unit_error().compat());
+		Ok::<_, ()>(futures01::Async::NotReady::<()>)
+	}));
 
 	runtime.block_on(future::join_all(import_notifications)
 		.unit_error().compat()).unwrap();