me/iced
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Use Skip as the MissedTickBehavior for tokio futures backend

Browse source
This commit is contained in:
Héctor Ramón Jiménez 2024-04-16 20:22:57 +02:00
parent 105b8bd5ad
commit e8ec6b94b6
No known key found for this signature in database
GPG key ID: 7CC46565708259A7
1 changed files with 8 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

14
futures/src/backend/native/tokio.rs
View file

@ -55,13 +55,15 @@ pub mod time {
let start = tokio::time::Instant::now() + self.0;
let mut interval = tokio::time::interval_at(start, self.0);
interval.set_missed_tick_behavior(
tokio::time::MissedTickBehavior::Skip,
);
let stream = {
futures::stream::unfold(
tokio::time::interval_at(start, self.0),
|mut interval| async move {
Some((interval.tick().await, interval))
},
)
futures::stream::unfold(interval, |mut interval| async move {
Some((interval.tick().await, interval))
})
};
stream.map(tokio::time::Instant::into_std).boxed()