diff --git a/src/capture.rs b/src/capture.rs
index 6d55cf9..6ac5e2a 100644
--- a/src/capture.rs
+++ b/src/capture.rs
@@ -1,6 +1,5 @@
 use std::{
     cell::Cell,
-    future,
     time::{Duration, Instant},
 };
 
diff --git a/src/connect.rs b/src/connect.rs
index 7d5c30f..c546ff4 100644
--- a/src/connect.rs
+++ b/src/connect.rs
@@ -211,7 +211,7 @@ async fn receive_loop(
     let mut buf = [0u8; MAX_EVENT_SIZE];
     while let Ok(_) = conn.recv(&mut buf).await {
         if let Ok(event) = buf.try_into() {
-            tx.send((handle, event));
+            tx.send((handle, event)).expect("channel closed");
         }
     }
 }
diff --git a/src/server.rs b/src/server.rs
index 6548259..f1fd7e7 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -92,6 +92,7 @@ impl Server {
         let config = Rc::new(config);
 
         Self {
+            active: Rc::new(Cell::new(None)),
             config,
             client_manager,
             port,