We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ee1d20c commit 86b40aaCopy full SHA for 86b40aa
src/driver.rs
@@ -179,6 +179,9 @@ pub fn block_on<T>(future: impl Future<Output = T>) -> T {
179
loop {
180
// Poll the future.
181
if let Poll::Ready(t) = future.as_mut().poll(cx) {
182
+ // Ensure the cached parker is reset to the unnotified state for future block_on calls,
183
+ // in case this future called wake and then immediately returned Poll::Ready.
184
+ p.park_timeout(Duration::from_secs(0));
185
tracing::trace!("completed");
186
return t;
187
}
0 commit comments