signal_stream: ignore unknown messagess (#369)

livekit · Jul 13, 2024 · 9119643 · 9119643
1 parent 4865f37
commit 9119643
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/livekit-api/src/signal_client/signal_stream.rs b/livekit-api/src/signal_client/signal_stream.rs
@@ -170,8 +170,9 @@ impl SignalStream {
                     let res = proto::SignalResponse::decode(data.as_slice())
                         .expect("failed to decode SignalResponse");
 
-                    let msg = res.message.unwrap();
-                    let _ = emitter.send(Box::new(msg));
+                    if let Some(msg) = res.message {
+                        let _ = emitter.send(Box::new(msg));
+                    }
                 }
                 Ok(Message::Ping(data)) => {
                     let _ = internal_tx.send(InternalMessage::Pong { ping_data: data }).await;