diff --git a/grpc/broadcaster/src/main.rs b/grpc/broadcaster/src/main.rs
index ff07dfd..0113bb9 100644
--- a/grpc/broadcaster/src/main.rs
+++ b/grpc/broadcaster/src/main.rs
@@ -58,7 +58,10 @@ impl MessageService {
         let tx_guard = self.shared_tx.lock().unwrap();
         let maybe_tx = tx_guard.borrow().upgrade();
         match maybe_tx {
-            Some(tx) => (tx.clone(), tx.subscribe()),
+            Some(tx) => {
+                let rx = tx.subscribe();
+                (tx, rx)
+            }
             None => {
                 let (tx, rx) = broadcast::channel(MESSAGE_QUEUE_SIZE);
                 let tx = Arc::new(tx);