monitored oneshots

paritytech · Sep 22, 2021 · 8a0d1c6 · 8a0d1c6
1 parent 4d07c25
commit 8a0d1c6
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::*};