Use an unbounded channel for waking `executor::Deterministic`

Antonio Scandurra , Nathan Sobo , and Max Brunsfeld created 4 years ago

Co-Authored-By: Nathan Sobo <[e-mail]>
Co-Authored-By: Max Brunsfeld <[e-mail]>

Change summary

gpui/src/executor.rs | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)

Detailed changes

gpui/src/executor.rs

@@ -13,7 +13,7 @@ use std::{
     rc::Rc,
     sync::{
         atomic::{AtomicBool, Ordering::SeqCst},
-        mpsc::SyncSender,
+        mpsc::Sender,
         Arc,
     },
     thread,
@@ -43,7 +43,7 @@ struct DeterministicState {
     seed: u64,
     scheduled: Vec<(Runnable, Backtrace)>,
     spawned_from_foreground: Vec<(Runnable, Backtrace)>,
-    waker: Option<SyncSender<()>>,
+    waker: Option<Sender<()>>,
 }
 
 pub struct Deterministic(Arc<Mutex<DeterministicState>>);
@@ -106,7 +106,7 @@ impl Deterministic {
         T: 'static,
         F: Future<Output = T> + 'static,
     {
-        let (wake_tx, wake_rx) = std::sync::mpsc::sync_channel(32);
+        let (wake_tx, wake_rx) = std::sync::mpsc::channel();
         let state = self.0.clone();
         state.lock().waker = Some(wake_tx);