From 2f6defce59640a9b3f7f94edf0368136ed6748d2 Mon Sep 17 00:00:00 2001
From: Yosh <github@yosh.is>
Date: Thu, 14 Mar 2024 15:40:19 +0100
Subject: [PATCH] fix CI

---
 src/future/futures_ext.rs | 4 ++++
 src/stream/stream_ext.rs  | 4 ++++
 src/stream/wait_until.rs  | 2 +-
 3 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/future/futures_ext.rs b/src/future/futures_ext.rs
index 3fc9fb2..329fea9 100644
--- a/src/future/futures_ext.rs
+++ b/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
diff --git a/src/stream/stream_ext.rs b/src/stream/stream_ext.rs
index 4f74eb7..8b6e9ef 100644
--- a/src/stream/stream_ext.rs
+++ b/src/stream/stream_ext.rs
@@ -34,6 +34,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};
@@ -51,6 +54,7 @@ pub trait StreamExt: Stream {
     ///
     ///     assert!(now.elapsed() >= duration);
     /// });
+    /// # }
     /// ```
     fn wait_until<D>(self, deadline: D) -> WaitUntil<Self, D::IntoFuture>
     where
diff --git a/src/stream/wait_until.rs b/src/stream/wait_until.rs
index 346fbc4..8731145 100644
--- a/src/stream/wait_until.rs
+++ b/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)