diff --git a/examples/src/bin/module_fetch_async.rs b/examples/src/bin/module_fetch_async.rs index 979e0b1db8d..29abebdd322 100644 --- a/examples/src/bin/module_fetch_async.rs +++ b/examples/src/bin/module_fetch_async.rs @@ -220,16 +220,9 @@ impl JobExecutor for Queue { group.insert(job.call(context)); } - if self.promise_jobs.borrow().is_empty() { - let Some(result) = group.next().await else { - // Both queues are empty. We can exit. - return Ok(()); - }; - - if let Err(err) = result { - eprintln!("Uncaught {err}"); - } - continue; + if group.is_empty() && self.promise_jobs.borrow().is_empty() { + // Both queues are empty. We can exit. + return Ok(()); } // We have some jobs pending on the microtask queue. Try to poll the pending diff --git a/examples/src/bin/smol_event_loop.rs b/examples/src/bin/smol_event_loop.rs index 315f0c3cc37..05c54b63119 100644 --- a/examples/src/bin/smol_event_loop.rs +++ b/examples/src/bin/smol_event_loop.rs @@ -111,16 +111,9 @@ impl JobExecutor for Queue { group.insert(job.call(context)); } - if self.promise_jobs.borrow().is_empty() { - let Some(result) = group.next().await else { - // Both queues are empty. We can exit. - return Ok(()); - }; - - if let Err(err) = result { - eprintln!("Uncaught {err}"); - } - continue; + if group.is_empty() && self.promise_jobs.borrow().is_empty() { + // Both queues are empty. We can exit. + return Ok(()); } // We could have some jobs pending on the microtask queue. Try to poll the pending diff --git a/examples/src/bin/tokio_event_loop.rs b/examples/src/bin/tokio_event_loop.rs index c5cb0903ba0..42141618a4d 100644 --- a/examples/src/bin/tokio_event_loop.rs +++ b/examples/src/bin/tokio_event_loop.rs @@ -116,17 +116,9 @@ impl JobExecutor for Queue { group.insert(job.call(context)); } - if self.promise_jobs.borrow().is_empty() { - let Some(result) = group.next().await else { - // Both queues are empty. We can exit. - return Ok(()); - }; - - if let Err(err) = result { - eprintln!("Uncaught {err}"); - } - - continue; + if group.is_empty() && self.promise_jobs.borrow().is_empty() { + // Both queues are empty. We can exit. + return Ok(()); } // We have some jobs pending on the microtask queue. Try to poll the pending