fix CI

Author: yoshuawuyts

src/future/futures_ext.rs

@@ -31,6 +31,9 @@ pub trait FutureExt: Future {
     /// # Example
     ///
     /// ```
+    /// # #[cfg(miri)]fn main() {}
+    /// # #[cfg(not(miri))]
+    /// # fn main() {
     /// use async_io::Timer;
     /// use futures_concurrency::prelude::*;
     /// use futures_lite::future::block_on;
@@ -46,6 +49,7 @@ pub trait FutureExt: Future {
     ///
     ///     assert!(now.elapsed() >= duration);
     /// });
+    /// # }
     /// ```
     fn wait_until<D>(self, deadline: D) -> WaitUntil<Self, D::IntoFuture>
     where

src/stream/stream_ext.rs

@@ -46,6 +46,9 @@ pub trait StreamExt: Stream {
     ///
     /// # Example
     /// ```
+    /// # #[cfg(miri)] fn main() {}
+    /// # #[cfg(not(miri))]
+    /// # fn main() {
     /// use async_io::Timer;
     /// use futures_concurrency::prelude::*;
     /// use futures_lite::{future::block_on, stream};
@@ -63,6 +66,7 @@ pub trait StreamExt: Stream {
     ///
     ///     assert!(now.elapsed() >= duration);
     /// });
+    /// # }
     /// ```
     fn wait_until<D>(self, deadline: D) -> WaitUntil<Self, D::IntoFuture>
     where

src/stream/wait_until.rs

@@ -51,7 +51,7 @@ where
 
         match this.state {
             State::Timer => match this.deadline.poll(cx) {
-                Poll::Pending => return Poll::Pending,
+                Poll::Pending => Poll::Pending,
                 Poll::Ready(_) => {
                     *this.state = State::Streaming;
                     this.stream.poll_next(cx)