Merge pull request #1761 from sgoll/fuse-ticker

Mark `Ticker` stream as fused

1 files changed, 8 insertions, 0 deletions

diff --git a/embassy-time/src/timer.rs b/embassy-time/src/timer.rs
index d3d1f9f5f..ad5026e62 100644
--- a/embassy-time/src/timer.rs
+++ b/embassy-time/src/timer.rs
@@ -3,6 +3,7 @@ use core::pin::Pin;
 use core::task::{Context, Poll, Waker};
 
 use futures_util::future::{select, Either};
+use futures_util::stream::FusedStream;
 use futures_util::{pin_mut, Stream};
 
 use crate::{Duration, Instant};
@@ -163,6 +164,13 @@ impl Stream for Ticker {
     }
 }
 
+impl FusedStream for Ticker {
+    fn is_terminated(&self) -> bool {
+        // `Ticker` keeps yielding values until dropped, it never terminates.
+        false
+    }
+}
+
 extern "Rust" {
     fn _embassy_time_schedule_wake(at: Instant, waker: &Waker);
 }