We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 440cb90 commit dd9a154Copy full SHA for dd9a154
src/capture.rs
@@ -1,6 +1,5 @@
1
use std::{
2
cell::Cell,
3
- future,
4
time::{Duration, Instant},
5
};
6
src/connect.rs
@@ -211,7 +211,7 @@ async fn receive_loop(
211
let mut buf = [0u8; MAX_EVENT_SIZE];
212
while let Ok(_) = conn.recv(&mut buf).await {
213
if let Ok(event) = buf.try_into() {
214
- tx.send((handle, event));
+ tx.send((handle, event)).expect("channel closed");
215
}
216
217
src/server.rs
@@ -92,6 +92,7 @@ impl Server {
92
let config = Rc::new(config);
93
94
Self {
95
+ active: Rc::new(Cell::new(None)),
96
config,
97
client_manager,
98
port,
0 commit comments