use super::Compat;
use futures::Stream as Stream01;

impl<St: Stream01> Stream01CompatExt for St {}

/// Extension trait for futures 0.1 [`Stream`][futures::Stream]
pub trait Stream01CompatExt: Stream01 {
    /// Converts a futures 0.1 [`Stream<Item = T, Error = E>`][futures::Stream]
    /// into a futures 0.3 [`Stream<Item = Result<T,
    /// E>>`][futures_core::Stream].
    fn compat(self) -> Compat<Self, ()>
    where
        Self: Sized,
    {
        Compat {
            inner: self,
            executor: None,
        }
    }
}

use super::Compat;
use futures::Stream as Stream01;

impl<St: Stream01> Stream01CompatExt for St {}

/// Extension trait for futures 0.1 [`Stream`][Stream01]
pub trait Stream01CompatExt: Stream01 {
    /// Converts a futures 0.1 [`Stream<Item = T, Error = E>`][Stream01] into a
    /// futures 0.3 [`Stream<Item = Result<T, E>>`][Stream03].
    fn compat(self) -> Compat<Self, ()>
    where
        Self: Sized,
    {
        Compat {
            inner: self,
            executor: None,
        }
    }
}

--- 
+++ 
@@ -3,10 +3,11 @@
 
 impl<St: Stream01> Stream01CompatExt for St {}
 
-/// Extension trait for futures 0.1 [`Stream`][Stream01]
+/// Extension trait for futures 0.1 [`Stream`][futures::Stream]
 pub trait Stream01CompatExt: Stream01 {
-    /// Converts a futures 0.1 [`Stream<Item = T, Error = E>`][Stream01] into a
-    /// futures 0.3 [`Stream<Item = Result<T, E>>`][Stream03].
+    /// Converts a futures 0.1 [`Stream<Item = T, Error = E>`][futures::Stream]
+    /// into a futures 0.3 [`Stream<Item = Result<T,
+    /// E>>`][futures_core::Stream].
     fn compat(self) -> Compat<Self, ()>
     where
         Self: Sized,
Fix doc links in futures-util::compat
