webrtc: fix message handler race (#38675)

open message handler early
2026-09-03 08:13:42 +08:00 · 2026-08-19 00:56:33 -04:00
parent 20fdc3d824
commit 5b36799eec
1 changed files with 4 additions and 1 deletions
@@ -335,9 +335,12 @@ class StreamSession:
  async def run(self):
    try:
      self.params.put("LivestreamRequestKeyframe", True)
+
+      # avoid datachannel race by adding messange_handler immediately
+      self.stream.set_message_handler(self.message_handler)
+
      await asyncio.wait_for(self.stream.wait_for_connection(), timeout=15)
      if self.stream.has_messaging_channel():
-        self.stream.set_message_handler(self.message_handler)
        if self.incoming_bridge is not None:
          await self.shared_pub_master.add_services_if_needed(self.incoming_bridge_services)
        if self.outgoing_bridge is not None: