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 fbefdbd commit b3217dbCopy full SHA for b3217db
src/hyperapp.rs
@@ -149,13 +149,14 @@ impl Executor {
149
}
150
151
pub fn poll_all_tasks(&mut self) {
152
+ let mut completed = Vec::new();
153
+
154
loop {
155
SPAWN_QUEUE.with(|queue| {
156
self.tasks.append(&mut queue.borrow_mut());
157
});
158
159
let mut ctx = Context::from_waker(noop_waker_ref());
- let mut completed = Vec::new();
160
161
for i in 0..self.tasks.len() {
162
if let Poll::Ready(()) = self.tasks[i].as_mut().poll(&mut ctx) {
@@ -165,6 +166,7 @@ impl Executor {
165
166
167
// tasks can spawn more tasks
168
let should_break = SPAWN_QUEUE.with(|queue| {
169
+ let queue = queue.borrow();
170
queue.is_empty()
171
172
if should_break {
0 commit comments