update example

Author: lukasIO

examples/data-streams/data_streams.py

@@ -54,14 +54,14 @@ def on_participant_connected(participant: rtc.RemoteParticipant):
         )
         asyncio.create_task(greetParticipant(participant.identity))
 
-    room.local_participant.set_text_stream_handler(
+    room.set_text_stream_handler(
         "chat",
         lambda reader, participant_identity: asyncio.create_task(
             on_chat_message_received(reader, participant_identity)
         ),
     )
 
-    room.local_participant.set_byte_stream_handler(
+    room.set_byte_stream_handler(
         "files",
         lambda reader, participant_identity: asyncio.create_task(
             on_welcome_image_received(reader, participant_identity)

livekit-rtc/livekit/rtc/participant.py

@@ -21,8 +21,6 @@
 import aiofiles
 from typing import List, Union, Callable, Dict, Awaitable, Optional, Mapping, cast
 from abc import abstractmethod, ABC
-import logging
-
 
 from ._ffi_client import FfiClient, FfiHandle
 from ._proto import ffi_pb2 as proto_ffi