nordic-dev.net/embassy
2
0
Fork 0
mirror of https://github.com/embassy-rs/embassy.git synced 2024-11-22 14:53:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1761 from sgoll/fuse-ticker

Browse Source 
Mark `Ticker` stream as fused
This commit is contained in:
Dario Nieuwenhuis 2023-08-08 23:14:24 +00:00 committed by GitHub
commit b7114fb951
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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);
} }