From fe9c419e5d80a89e359ca7cd0cd7bc5dcf0b4e25 Mon Sep 17 00:00:00 2001 From: Floris Bruynooghe Date: Sat, 23 Jan 2021 22:30:09 +0100 Subject: [PATCH] Update tests to new async-std channel api --- src/securejoin/mod.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/securejoin/mod.rs b/src/securejoin/mod.rs index b98b3f40c..06444f1ee 100644 --- a/src/securejoin/mod.rs +++ b/src/securejoin/mod.rs @@ -922,7 +922,7 @@ mod tests { let bob = TestContext::new_bob().await; // Setup JoinerProgress sinks. - let (joiner_progress_tx, joiner_progress_rx) = async_std::sync::channel(100); + let (joiner_progress_tx, joiner_progress_rx) = async_std::channel::bounded(100); bob.add_event_sink(move |event: Event| { let joiner_progress_tx = joiner_progress_tx.clone(); async move { @@ -1112,7 +1112,7 @@ mod tests { let bob = TestContext::new_bob().await; // Setup JoinerProgress sinks. - let (joiner_progress_tx, joiner_progress_rx) = async_std::sync::channel(100); + let (joiner_progress_tx, joiner_progress_rx) = async_std::channel::bounded(100); bob.add_event_sink(move |event: Event| { let joiner_progress_tx = joiner_progress_tx.clone(); async move { @@ -1262,7 +1262,7 @@ mod tests { let bob = TestContext::new_bob().await; // Setup JoinerProgress sinks. - let (joiner_progress_tx, joiner_progress_rx) = async_std::sync::channel(100); + let (joiner_progress_tx, joiner_progress_rx) = async_std::channel::bounded(100); bob.add_event_sink(move |event: Event| { let joiner_progress_tx = joiner_progress_tx.clone(); async move {