fix

Author: theomonnom

livekit-rtc/livekit/rtc/participant.py

@@ -704,7 +704,7 @@ async def publish_track(
                 raise PublishTrackError(cb.publish_track.error)
 
             track_publication = LocalTrackPublication(cb.publish_track.publication)
-            track_publication.track = track
+            track_publication._track = track
             track._info.sid = track_publication.sid
             self._track_publications[track_publication.sid] = track_publication
 
@@ -739,7 +739,7 @@ async def unpublish_track(self, track_sid: str) -> None:
                 raise UnpublishTrackError(cb.unpublish_track.error)
 
             publication = self._track_publications.pop(track_sid)
-            publication.track = None
+            publication._track = None
             queue.task_done()
         finally:
             self._room_queue.unsubscribe(queue)

livekit-rtc/livekit/rtc/room.py

@@ -535,22 +535,22 @@ def _on_room_event(self, event: proto_room.RoomEvent):
             track_info = owned_track_info.info
             rparticipant = self._remote_participants[event.track_subscribed.participant_identity]
             rpublication = rparticipant.track_publications[track_info.sid]
-            rpublication.subscribed = True
+            rpublication._subscribed = True
             if track_info.kind == TrackKind.KIND_VIDEO:
                 remote_video_track = RemoteVideoTrack(owned_track_info)
-                rpublication.track = remote_video_track
+                rpublication._track = remote_video_track
                 self.emit("track_subscribed", remote_video_track, rpublication, rparticipant)
             elif track_info.kind == TrackKind.KIND_AUDIO:
                 remote_audio_track = RemoteAudioTrack(owned_track_info)
-                rpublication.track = remote_audio_track
+                rpublication._track = remote_audio_track
                 self.emit("track_subscribed", remote_audio_track, rpublication, rparticipant)
         elif which == "track_unsubscribed":
             identity = event.track_unsubscribed.participant_identity
             rparticipant = self._remote_participants[identity]
             rpublication = rparticipant.track_publications[event.track_unsubscribed.track_sid]
             track = rpublication.track
-            rpublication.track = None
-            rpublication.subscribed = False
+            rpublication._track = None
+            rpublication._subscribed = False
             self.emit("track_unsubscribed", track, rpublication, rparticipant)
         elif which == "track_subscription_failed":
             identity = event.track_subscription_failed.participant_identity