OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-22 22:46:39 +01:00
Code Issues Projects Releases Packages Wiki Activity

Use waker API instead of recursing

Browse source
This commit is contained in:
Maybe Waffle 2023-09-25 20:45:27 +04:00
parent 808a0cf4fb
commit 2b7eea2679
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
crates/teloxide/src/update_listeners/polling.rs
View file

@ -406,8 +406,10 @@ impl<B: Requester> Stream for PollingStream<'_, B> {
.send(); .send();
this.in_flight.set(Some(req)); this.in_flight.set(Some(req));
// Recurse to poll `self.in_flight` // Immediately wake up to poll `self.in_flight`
self.poll_next(cx) // (without this this stream becomes a zombie)
cx.waker().wake_by_ref();
Poll::Pending
} }
} }