Format

Author: ladvoc

examples/data_tracks/publisher.py

@@ -8,10 +8,12 @@
 TOKEN = os.environ.get("LIVEKIT_TOKEN")
 URL = os.environ.get("LIVEKIT_URL")
 
+
 async def read_sensor() -> bytes:
     # Dynamically read some sensor data...
     return bytes([0xFA] * 256)
 
+
 async def push_frames(track: rtc.LocalDataTrack):
     while True:
         logging.info("Pushing frame")
@@ -23,6 +25,7 @@ async def push_frames(track: rtc.LocalDataTrack):
             logging.error("Failed to push frame: %s", e)
         await asyncio.sleep(0.5)
 
+
 async def main(room: rtc.Room):
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)
@@ -33,6 +36,7 @@ async def main(room: rtc.Room):
     track = await room.local_participant.publish_data_track("my_sensor_data")
     await push_frames(track)
 
+
 if __name__ == "__main__":
     logging.basicConfig(
         level=logging.INFO,

examples/data_tracks/subscriber.py

@@ -8,6 +8,7 @@
 TOKEN = os.environ.get("LIVEKIT_TOKEN")
 URL = os.environ.get("LIVEKIT_URL")
 
+
 async def subscribe(track: rtc.RemoteDataTrack):
     logging.info(
         "Subscribing to '%s' published by '%s'",
@@ -22,6 +23,7 @@ async def subscribe(track: rtc.RemoteDataTrack):
         if latency is not None:
             logging.info("Latency: %.3f s", latency)
 
+
 async def main(room: rtc.Room):
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)