monitored oneshots

paritytech · Sep 22, 2021 · 5f2ad61 · 5f2ad61
1 parent ffa8617
commit 5f2ad61
Show file tree

Hide file tree

Showing 5 changed files with 405 additions and 18 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/node/metered-channel/Cargo.toml b/node/metered-channel/Cargo.toml
@@ -9,6 +9,13 @@ description = "Channels with attached Meters"
 futures = "0.3.17"
 futures-timer = "3.0.2"
 derive_more = "0.99"
+tracing = "0.1.28"
+thiserror = "1.0.29"
+num_enum = "0.5.4"
 
 [dev-dependencies]
 futures = { version = "0.3.17", features = ["thread-pool"] }
+assert_matches = "1.5"
+env_logger = "0.9"
+log = "0.4"
+tracing = { version = "0.1.28", features = ["log"] }
diff --git a/node/metered-channel/src/lib.rs b/node/metered-channel/src/lib.rs
@@ -24,6 +24,7 @@ use std::sync::{
 use derive_more::{Add, Display};
 
 mod bounded;
+pub mod oneshot;
 mod unbounded;
 
 pub use self::{bounded::*, unbounded::*};