write to disk in example and fix asyncio bug

Author: lukasIO

examples/data-streams/data_streams.py

@@ -41,6 +41,11 @@ async def on_welcome_image_received(
         logger.info(
             "Received image from %s: '%s'", participant_identity, reader.info["name"]
         )
+        with open(reader.info["name"], mode="wb") as f:
+            async for chunk in reader:
+                f.write(chunk)
+
+            f.close()
 
     @room.on("participant_connected")
     def on_participant_connected(participant: rtc.RemoteParticipant):
@@ -76,7 +81,10 @@ def on_participant_connected(participant: rtc.RemoteParticipant):
 if __name__ == "__main__":
     logging.basicConfig(
         level=logging.INFO,
-        handlers=[logging.FileHandler("basic_room.log"), logging.StreamHandler()],
+        handlers=[
+            logging.FileHandler("data_stream_example.log"),
+            logging.StreamHandler(),
+        ],
     )
 
     loop = asyncio.get_event_loop()

livekit-rtc/livekit/rtc/room.py

@@ -747,9 +747,9 @@ def _on_room_event(self, event: proto_room.RoomEvent):
                 event.stream_header_received.participant_identity,
             )
         elif which == "stream_chunk_received":
-            asyncio.run(self._handle_stream_chunk(event.stream_chunk_received.chunk))
+            asyncio.gather(self._handle_stream_chunk(event.stream_chunk_received.chunk))
         elif which == "stream_trailer_received":
-            asyncio.run(
+            asyncio.gather(
                 self._handle_stream_trailer(event.stream_trailer_received.trailer)
             )