diff --git a/common/task/src/connections.rs b/common/task/src/connections.rs index af13111526c..6739ecf9f50 100644 --- a/common/task/src/connections.rs +++ b/common/task/src/connections.rs @@ -103,4 +103,8 @@ impl LaneQueueLengthsInner { { self.map.entry(*lane).and_modify(f); } + + pub fn total(&self) -> usize { + self.map.values().sum() + } } diff --git a/sdk/rust/nym-sdk/src/mixnet.rs b/sdk/rust/nym-sdk/src/mixnet.rs index 6fc8cae2dc0..b540aa752df 100644 --- a/sdk/rust/nym-sdk/src/mixnet.rs +++ b/sdk/rust/nym-sdk/src/mixnet.rs @@ -82,7 +82,7 @@ pub use nym_sphinx::{ pub use nym_statistics_common::clients::{ connection::ConnectionStatsEvent, ClientStatsEvents, ClientStatsSender, }; -pub use nym_task::connections::TransmissionLane; +pub use nym_task::connections::{LaneQueueLengths, TransmissionLane}; pub use nym_topology::{provider_trait::TopologyProvider, NymTopology}; pub use paths::StoragePaths; pub use socks5_client::Socks5MixnetClient;