futures 0.1 extension trait

Author: tinaun

futures-util/src/compat/mod.rs

@@ -133,3 +133,16 @@ impl Wake for Current {
         arc_self.0.notify();
     }
 }
+
+/// Extension trait for futures 0.1.
+pub trait Future01Ext: Future01 {
+    /// Converts the future into a futures 0.3 future.
+    fn compat(self) -> Compat<Self, ()> where Self: Sized {
+        Compat {
+            inner: self,
+            executor: None,
+        }
+    }
+}
+
+impl<T: Future01> Future01Ext for T {}

futures-util/src/future/mod.rs

@@ -68,6 +68,8 @@ mod chain;
 crate use self::chain::Chain;
 
 if_std! {
+    use std::boxed::PinBox;
+
     mod abortable;
     pub use self::abortable::{abortable, Abortable, AbortHandle, AbortRegistration, Aborted};
 
@@ -86,8 +88,6 @@ if_std! {
 
     mod shared;
     pub use self::shared::Shared;
-
-    use std::boxed::PinBox;
 }
 
 impl<T: ?Sized> FutureExt for T where T: Future {}

futures-util/src/future/never_error.rs

@@ -29,11 +29,6 @@ impl<Fut, T> Future for NeverError<Fut>
     type Output = Result<T, ()>;
 
     fn poll(mut self: PinMut<Self>, cx: &mut task::Context) -> Poll<Result<T, ()>> {
-        match self.future().poll(cx) {
-            Poll::Pending => Poll::Pending,
-            Poll::Ready(output) => {
-                Poll::Ready(Ok(output))
-            }
-        }
+        self.future().poll(cx).map(Ok)
     }
 }