Skip to content

Commit 0a1ceba

Browse files
authored
fix: type errors with republished event (#657)
1 parent 082b826 commit 0a1ceba

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

livekit-rtc/livekit/rtc/room.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -740,11 +740,12 @@ def _on_room_event(self, event: proto_room.RoomEvent):
740740
# reference continues to see current state, then rekey it
741741
# under the new SID in the participant's publications dict.
742742
previous_sid = event.local_track_republished.previous_sid
743-
lpublication = self.local_participant._track_publications.pop(previous_sid, None)
744-
if lpublication is not None:
745-
lpublication._info = event.local_track_republished.info
746-
self.local_participant._track_publications[lpublication.sid] = lpublication
747-
self.emit("local_track_republished", lpublication, previous_sid)
743+
republished = self.local_participant._track_publications.get(previous_sid)
744+
if republished is not None:
745+
del self.local_participant._track_publications[previous_sid]
746+
republished._info = event.local_track_republished.info
747+
self.local_participant._track_publications[republished.sid] = republished
748+
self.emit("local_track_republished", republished, previous_sid)
748749
elif which == "local_track_subscribed":
749750
sid = event.local_track_subscribed.track_sid
750751
lpublication = self.local_participant.track_publications[sid]

0 commit comments

Comments
 (0)