max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Mark Ticker stream as FusedStream

Browse Source
This commit is contained in:
Sebastian Goll 2023-08-09 00:10:48 +02:00
parent 47b8e04b1c
commit c40b944da6
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
embassy-time/src/timer.rs
View File

@ -3,6 +3,7 @@ use core::pin::Pin;
use core::task::{Context, Poll, Waker}; use core::task::{Context, Poll, Waker};
use futures_util::future::{select, Either}; use futures_util::future::{select, Either};
use futures_util::stream::FusedStream;
use futures_util::{pin_mut, Stream}; use futures_util::{pin_mut, Stream};
use crate::{Duration, Instant}; 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" { extern "Rust" {
fn _embassy_time_schedule_wake(at: Instant, waker: &Waker); fn _embassy_time_schedule_wake(at: Instant, waker: &Waker);
} }