Update examples/wxpy_room/wxpy_room.py

Co-authored-by: devin-ai-integration[bot] <158243242+devin-ai-integration[bot]@users.noreply.github.com>

Author: cloudwebrtc

examples/wxpy_room/wxpy_room.py

@@ -362,12 +362,14 @@ def _on_track_unsubscribed(self, track, publication, participant):
         logger.info("Track unsubscribed: %s from %s", track.sid, participant.identity)
         identity = self._track_to_participant.pop(track.sid, None)
         if identity:
-            stream = self._video_streams.pop(identity, None)
-            if stream:
-                asyncio.ensure_future(stream.aclose())
-            stream = self._audio_streams.pop(identity, None)
-            if stream:
-                asyncio.ensure_future(stream.aclose())
+            if track.kind == rtc.TrackKind.KIND_VIDEO:
+                stream = self._video_streams.pop(identity, None)
+                if stream:
+                    asyncio.ensure_future(stream.aclose())
+            elif track.kind == rtc.TrackKind.KIND_AUDIO:
+                stream = self._audio_streams.pop(identity, None)
+                if stream:
+                    asyncio.ensure_future(stream.aclose())
 
     def _on_local_track_published(self, publication, track):
         logger.info("Local track published: %s (kind=%s)", publication.sid, track.kind)