From 3092444ef3943e367b7f724f84a40b95ed61b549 Mon Sep 17 00:00:00 2001 From: Herr Seppia Date: Wed, 11 Sep 2024 13:53:33 +0200 Subject: [PATCH 1/2] move back to async internal channel --- src/transport.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/transport.rs b/src/transport.rs index a4c132a..30992aa 100644 --- a/src/transport.rs +++ b/src/transport.rs @@ -99,7 +99,8 @@ impl WireNetwork { } dec_chan_tx - .try_send((bytes[0..len].to_vec(), remote_address)) + .send((bytes[0..len].to_vec(), remote_address)) + .await .unwrap_or_else(|e| { error!("Unable to send to dec_chan_tx channel {e}") }); From 2417b4b2eed352bd3473d2862ad02f3a65f8376b Mon Sep 17 00:00:00 2001 From: Herr Seppia Date: Wed, 11 Sep 2024 13:54:19 +0200 Subject: [PATCH 2/2] Bump version to `0.7.0-rc.6` --- Cargo.toml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 6d16f27..18256cf 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "kadcast" authors = ["herr-seppia "] -version = "0.7.0-rc.5" +version = "0.7.0-rc.6" edition = "2018" description = "Implementation of the Kadcast Network Protocol." categories = ["network-programming"]