TrackSubscribed -> LocalTrackSubscribed everywhere

livekit · Aug 19, 2024 · a504aad · a504aad
1 parent ad4baad
commit a504aad
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/livekit/src/room/mod.rs b/livekit/src/room/mod.rs
@@ -614,7 +614,7 @@ impl RoomSession {
             EngineEvent::ConnectionQuality { updates } => {
                 self.handle_connection_quality_update(updates)
             }
-            EngineEvent::TrackSubscribed { track_sid } => self.handle_track_subscribed(track_sid),
+            EngineEvent::LocalTrackSubscribed { track_sid } => self.handle_track_subscribed(track_sid),
             // RequestResponse is required for protocol version 14, but we don't use it
             EngineEvent::RequestResponse { request_id, message, reason } => {}
         }

diff --git a/livekit/src/rtc_engine/mod.rs b/livekit/src/rtc_engine/mod.rs
@@ -136,7 +136,7 @@ pub enum EngineEvent {
     Disconnected {
         reason: DisconnectReason,
     },
-    TrackSubscribed {
+    LocalTrackSubscribed {
         track_sid: String,
     },
     RequestResponse {
@@ -457,8 +457,8 @@ impl EngineInner {
             SessionEvent::RoomUpdate { room } => {
                 let _ = self.engine_tx.send(EngineEvent::RoomUpdate { room });
             }
-            SessionEvent::TrackSubscribed { track_sid } => {
-                let _ = self.engine_tx.send(EngineEvent::TrackSubscribed { track_sid });
+            SessionEvent::LocalTrackSubscribed { track_sid } => {
+                let _ = self.engine_tx.send(EngineEvent::LocalTrackSubscribed { track_sid });
             }
             SessionEvent::RequestResponse { request_id, message, reason } => {
                 let _ = self.engine_tx.send(EngineEvent::RequestResponse {

diff --git a/livekit/src/rtc_engine/rtc_session.rs b/livekit/src/rtc_engine/rtc_session.rs
@@ -106,7 +106,7 @@ pub enum SessionEvent {
     RoomUpdate {
         room: proto::Room,
     },
-    TrackSubscribed {
+    LocalTrackSubscribed {
         track_sid: String,
     },
     Close {
@@ -507,7 +507,7 @@ impl SessionInner {
             proto::signal_response::Message::TrackSubscribed(track_subscribed) => {
                 let _ = self
                     .emitter
-                    .send(SessionEvent::TrackSubscribed { track_sid: track_subscribed.track_sid });
+                    .send(SessionEvent::LocalTrackSubscribed { track_sid: track_subscribed.track_sid });
             }
             proto::signal_response::Message::RequestResponse(request_response) => {
                 let _ = self.emitter.send(SessionEvent::RequestResponse {