diff --git a/examples/livecoding_channels.rs b/examples/livecoding_channels.rs index 6038d14..9003d0a 100644 --- a/examples/livecoding_channels.rs +++ b/examples/livecoding_channels.rs @@ -16,7 +16,7 @@ async fn main() -> Result<(), Box> { .filter(| url | url.host() != addr.host()) .collect(); - let (tx, mut rx) = mpsc::channel(32); + let (tx, mut rx) = mpsc::channel(WORKERS); // spawn a pool of workers let mut workers : Vec>> = (0..WORKERS) @@ -57,7 +57,7 @@ fn spawn_worker( id: usize, tx: Sender<(usize,Option)> ) -> Sender { - let (tx1, mut rx) = mpsc::channel::(16); + let (tx1, mut rx) = mpsc::channel::(1); tokio::spawn(async move { println!("Start worker {id}");