Bump minimum pipe capacity to 1

0 causes a runtime error: The application panicked (crashed). Message: capacity is empty Location: robotica-backend/src/pipes/stateful/receiver.rs:269 Backtrace omitted. Run with RUST_BACKTRACE=1 environment variable to display it. Run with RUST_BACKTRACE=full to include source snippets.
brianmay · Sep 10, 2023 · caba592 · caba592
1 parent 800370d
commit caba592
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/robotica-backend/src/pipes/stateful/receiver.rs b/robotica-backend/src/pipes/stateful/receiver.rs
@@ -266,7 +266,7 @@ where
 {
     /// Create a null subscription that is already closed.
     fn null(tx: mpsc::Sender<ReceiveMessage<T>>) -> Self {
-        let (_tx, rx) = broadcast::channel(0);
+        let (_tx, rx) = broadcast::channel(1);
         Self {
             rx,
             _tx: tx,

diff --git a/robotica-backend/src/pipes/stateless/receiver.rs b/robotica-backend/src/pipes/stateless/receiver.rs
@@ -240,7 +240,7 @@ where
 {
     /// Create a null subscription that is already closed.
     fn null(tx: mpsc::Sender<ReceiveMessage<T>>) -> Self {
-        let (_tx, rx) = broadcast::channel(0);
+        let (_tx, rx) = broadcast::channel(1);
         Self { rx, _tx: tx }
     }
 }