We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bd76282 commit eb8ae4aCopy full SHA for eb8ae4a
src/manager.rs
@@ -82,6 +82,14 @@ impl Manager {
82
tracing::warn!("unexpected event_ch ended prematurely on remove: {:?}", err);
83
}
84
85
+
86
+ pub fn is_empty(&self) -> bool {
87
+ self.conns.is_empty()
88
+ }
89
90
+ pub fn len(&self) -> usize {
91
+ self.conns.len()
92
93
94
95
#[derive(Debug, Clone)]
src/server.rs
@@ -19,7 +19,7 @@ const KEEP_ALIVE_INTERVAL: Duration = Duration::from_secs(45);
19
20
#[derive(Clone)]
21
pub struct Server {
22
- manager: Manager,
+ pub manager: Manager,
23
24
25
pub type MessageStream = Pin<Box<dyn Stream<Item = proto::Message> + Send>>;
0 commit comments