chore: replace all doctest usage of pin_mut with pin

Signed-off-by: tison <[email protected]>

Author: tisonkun

futures-test/src/assert.rs

@@ -9,15 +9,16 @@ pub fn assert_is_unpin_stream<S: Stream + Unpin>(_: &mut S) {}
 /// # Examples
 ///
 /// ```
+/// use core::pin::pin;
+///
 /// use futures::stream;
 /// use futures_test::future::FutureTestExt;
-/// use futures_test::{
-///     assert_stream_pending, assert_stream_next, assert_stream_done,
-/// };
-/// use futures::pin_mut;
+/// use futures_test::assert_stream_pending;
+/// use futures_test::assert_stream_next;
+/// use futures_test::assert_stream_done;
 ///
 /// let stream = stream::once((async { 5 }).pending_once());
-/// pin_mut!(stream);
+/// let mut stream = pin!(stream);
 ///
 /// assert_stream_pending!(stream);
 /// assert_stream_next!(stream, 5);
@@ -46,15 +47,16 @@ macro_rules! assert_stream_pending {
 /// # Examples
 ///
 /// ```
+/// use core::pin::pin;
+///
 /// use futures::stream;
 /// use futures_test::future::FutureTestExt;
-/// use futures_test::{
-///     assert_stream_pending, assert_stream_next, assert_stream_done,
-/// };
-/// use futures::pin_mut;
+/// use futures_test::assert_stream_pending;
+/// use futures_test::assert_stream_next;
+/// use futures_test::assert_stream_done;
 ///
 /// let stream = stream::once((async { 5 }).pending_once());
-/// pin_mut!(stream);
+/// let mut stream = pin!(stream);
 ///
 /// assert_stream_pending!(stream);
 /// assert_stream_next!(stream, 5);
@@ -90,15 +92,16 @@ macro_rules! assert_stream_next {
 /// # Examples
 ///
 /// ```
+/// use core::pin::pin;
+///
 /// use futures::stream;
 /// use futures_test::future::FutureTestExt;
-/// use futures_test::{
-///     assert_stream_pending, assert_stream_next, assert_stream_done,
-/// };
-/// use futures::pin_mut;
+/// use futures_test::assert_stream_pending;
+/// use futures_test::assert_stream_next;
+/// use futures_test::assert_stream_done;
 ///
 /// let stream = stream::once((async { 5 }).pending_once());
-/// pin_mut!(stream);
+/// let mut stream = pin!(stream);
 ///
 /// assert_stream_pending!(stream);
 /// assert_stream_next!(stream, 5);

futures-test/src/future/mod.rs

@@ -32,14 +32,15 @@ pub trait FutureTestExt: Future {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::future::FutureExt;
     /// use futures_test::task::noop_context;
     /// use futures_test::future::FutureTestExt;
-    /// use futures::pin_mut;
     ///
     /// let future = (async { 5 }).pending_once();
-    /// pin_mut!(future);
+    /// let mut future = pin!(future);
     ///
     /// let mut cx = noop_context();
     ///
@@ -84,14 +85,15 @@ pub trait FutureTestExt: Future {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::future::{self, Future};
     /// use futures_test::task::noop_context;
     /// use futures_test::future::FutureTestExt;
-    /// use futures::pin_mut;
     ///
     /// let future = future::ready(1).interleave_pending();
-    /// pin_mut!(future);
+    /// let mut future = pin!(future);
     ///
     /// let mut cx = noop_context();
     ///

futures-test/src/io/read/mod.rs

@@ -29,14 +29,15 @@ pub trait AsyncReadTestExt: AsyncRead {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::io::{AsyncRead, Cursor};
     /// use futures_test::task::noop_context;
     /// use futures_test::io::AsyncReadTestExt;
-    /// use futures::pin_mut;
     ///
     /// let reader = Cursor::new(&[1, 2, 3]).interleave_pending();
-    /// pin_mut!(reader);
+    /// let mut reader = pin!(reader);
     ///
     /// let mut cx = noop_context();
     ///
@@ -59,14 +60,15 @@ pub trait AsyncReadTestExt: AsyncRead {
     /// The returned reader will also implement `AsyncBufRead` if the underlying reader does.
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::io::{AsyncBufRead, Cursor};
     /// use futures_test::task::noop_context;
     /// use futures_test::io::AsyncReadTestExt;
-    /// use futures::pin_mut;
     ///
     /// let reader = Cursor::new(&[1, 2, 3]).interleave_pending();
-    /// pin_mut!(reader);
+    /// let mut reader = pin!(reader);
     ///
     /// let mut cx = noop_context();
     ///
@@ -93,14 +95,15 @@ pub trait AsyncReadTestExt: AsyncRead {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::io::{AsyncRead, Cursor};
     /// use futures_test::task::noop_context;
     /// use futures_test::io::AsyncReadTestExt;
-    /// use futures::pin_mut;
     ///
     /// let reader = Cursor::new(&[1, 2, 3, 4, 5]).limited(2);
-    /// pin_mut!(reader);
+    /// let mut reader = pin!(reader);
     ///
     /// let mut cx = noop_context();
     ///

futures-test/src/io/write/mod.rs

@@ -30,14 +30,15 @@ pub trait AsyncWriteTestExt: AsyncWrite {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::io::{AsyncWrite, Cursor};
     /// use futures_test::task::noop_context;
     /// use futures_test::io::AsyncWriteTestExt;
-    /// use futures::pin_mut;
     ///
     /// let writer = Cursor::new(vec![0u8; 4].into_boxed_slice()).interleave_pending_write();
-    /// pin_mut!(writer);
+    /// let mut writer = pin!(writer);
     ///
     /// let mut cx = noop_context();
     ///
@@ -70,14 +71,15 @@ pub trait AsyncWriteTestExt: AsyncWrite {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::io::{AsyncWrite, Cursor};
     /// use futures_test::task::noop_context;
     /// use futures_test::io::AsyncWriteTestExt;
-    /// use futures::pin_mut;
     ///
     /// let writer = Cursor::new(vec![0u8; 4].into_boxed_slice()).limited_write(2);
-    /// pin_mut!(writer);
+    /// let mut writer = pin!(writer);
     ///
     /// let mut cx = noop_context();
     ///

futures-test/src/stream/mod.rs

@@ -28,14 +28,15 @@ pub trait StreamTestExt: Stream {
     /// # Examples
     ///
     /// ```
+    /// use core::pin::pin;
+    ///
     /// use futures::task::Poll;
     /// use futures::stream::{self, Stream};
     /// use futures_test::task::noop_context;
     /// use futures_test::stream::StreamTestExt;
-    /// use futures::pin_mut;
     ///
     /// let stream = stream::iter(vec![1, 2]).interleave_pending();
-    /// pin_mut!(stream);
+    /// let mut stream = pin!(stream);
     ///
     /// let mut cx = noop_context();
     ///

futures-test/src/task/context.rs

@@ -22,13 +22,14 @@ pub fn panic_context() -> Context<'static> {
 /// # Examples
 ///
 /// ```
+/// use core::pin::pin;
+///
 /// use futures::future::Future;
 /// use futures::task::Poll;
 /// use futures_test::task::noop_context;
-/// use futures::pin_mut;
 ///
 /// let future = async { 5 };
-/// pin_mut!(future);
+/// let mut future = pin!(future);
 ///
 /// assert_eq!(future.poll(&mut noop_context()), Poll::Ready(5));
 /// ```