Merge pull request #18 from kpp/fix_doc

Fix doc ^C^V

Author: kpp

src/future.rs

@@ -100,11 +100,11 @@ pub async fn then<FutA, FutB, F>(future: FutA, f: F) -> FutB::Output
 ///
 /// ```
 /// #![feature(async_await)]
-/// use futures::future::{self, TryFutureExt};
+/// use futures_async_combinators::future::{ready, and_then};
 ///
 /// # futures::executor::block_on(async {
-/// let future = future::ready(Ok::<i32, i32>(1));
-/// let future = future.and_then(|x| future::ready(Ok::<i32, i32>(x + 3)));
+/// let future = ready(Ok::<i32, i32>(1));
+/// let future = and_then(future, |x| ready(Ok::<i32, i32>(x + 3)));
 /// assert_eq!(future.await, Ok(4));
 /// # });
 /// ```

src/stream.rs

@@ -473,7 +473,6 @@ pub fn flatten<St, SubSt, T>(stream: St) -> impl Stream<Item = T>
 /// ```
 /// #![feature(async_await)]
 /// # futures::executor::block_on(async {
-/// use futures::future;
 /// use futures_async_combinators::{future::ready, stream::{iter, then, collect}};
 ///
 /// let stream = iter(1..=3);
@@ -634,7 +633,6 @@ pub fn chain<St>(stream: St, other: St) -> impl Stream<Item = St::Item>
 /// ```
 /// #![feature(async_await)]
 /// # futures::executor::block_on(async {
-/// use futures::future;
 /// use futures_async_combinators::{future::ready, stream::{iter, take_while, collect}};
 ///
 /// let stream = iter(1..=10);