diff --git a/examples/data-streams/data_streams.py b/examples/data-streams/data_streams.py
index c35152c2..4fca74cd 100644
--- a/examples/data-streams/data_streams.py
+++ b/examples/data-streams/data_streams.py
@@ -13,6 +13,8 @@ async def main(room: rtc.Room):
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)
 
+    active_tasks = []
+
     async def greetParticipant(identity: str):
         text_writer = await room.local_participant.stream_text(
             destination_identities=[identity], topic="chat"
@@ -32,8 +34,8 @@ async def on_chat_message_received(reader: rtc.TextStreamReader, participant_ide
         logger.info("Received chat message from %s: '%s'", participant_identity, full_text)
 
     async def on_welcome_image_received(reader: rtc.ByteStreamReader, participant_identity: str):
-        logger.info("Received image from %s: '%s'", participant_identity, reader.info["name"])
-        with open(reader.info["name"], mode="wb") as f:
+        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)
 
@@ -44,19 +46,19 @@ def on_participant_connected(participant: rtc.RemoteParticipant):
         logger.info("participant connected: %s %s", participant.sid, participant.identity)
         asyncio.create_task(greetParticipant(participant.identity))
 
-    room.set_text_stream_handler(
-        "chat",
-        lambda reader, participant_identity: asyncio.create_task(
-            on_chat_message_received(reader, participant_identity)
-        ),
-    )
+    def _handle_chat_stream(reader, participant_identity):
+        task = asyncio.create_task(on_chat_message_received(reader, participant_identity))
+        active_tasks.append(task)
+        task.add_done_callback(lambda _: active_tasks.remove(task))
 
-    room.set_byte_stream_handler(
-        "files",
-        lambda reader, participant_identity: asyncio.create_task(
-            on_welcome_image_received(reader, participant_identity)
-        ),
-    )
+    room.set_text_stream_handler("chat", _handle_chat_stream)
+
+    def _handle_welcome_image_stream(reader, participant_identity):
+        task = asyncio.create_task(on_welcome_image_received(reader, participant_identity))
+        active_tasks.append(task)
+        task.add_done_callback(lambda _: active_tasks.remove(task))
+
+    room.set_byte_stream_handler("files", _handle_welcome_image_stream)
 
     # By default, autosubscribe is enabled. The participant will be subscribed to
     # all published tracks in the room
diff --git a/livekit-api/README.md b/livekit-api/README.md
index c4b77002..14b5e35f 100644
--- a/livekit-api/README.md
+++ b/livekit-api/README.md
@@ -1,3 +1,6 @@
 # LiveKit Server APIs
 
 Access LiveKit server APIs and generate access tokens.
+
+See https://docs.livekit.io/reference/server/server-apis for more information.
+
diff --git a/livekit-api/livekit/api/room_service.py b/livekit-api/livekit/api/room_service.py
index b12469c4..3d521548 100644
--- a/livekit-api/livekit/api/room_service.py
+++ b/livekit-api/livekit/api/room_service.py
@@ -215,7 +215,11 @@ async def forward_participant(self, forward: ForwardParticipantRequest) -> None:
             SVC,
             "ForwardParticipant",
             forward,
-            self._auth_header(VideoGrants(room_admin=True, room=forward.room, destination_room=forward.destination_room)),
+            self._auth_header(
+                VideoGrants(
+                    room_admin=True, room=forward.room, destination_room=forward.destination_room
+                )
+            ),
             ForwardParticipantResponse,
         )
 
diff --git a/livekit-rtc/README.md b/livekit-rtc/README.md
index 105e723f..516f9b6c 100644
--- a/livekit-rtc/README.md
+++ b/livekit-rtc/README.md
@@ -1,3 +1,6 @@
-# LiveKit Real-time Python SDK
+# LiveKit SDK for Python
+
+Python SDK to integrate LiveKit's real-time video, audio, and data capabilities into your Python applications using WebRTC. Designed for use with [LiveKit Agents](https://github.com/livekit/agents) to build powerful voice AI apps.
+
+See https://docs.livekit.io/ for more information.
 
-The LiveKit Python SDK provides a convenient interface for integrating LiveKit's real-time video and audio capabilities into your Python applications. With it, developers can easily leverage LiveKit's WebRTC functionalities, allowing them to focus on building their AI models or other application logic without worrying about the complexities of WebRTC.
diff --git a/livekit-rtc/livekit/rtc/__init__.py b/livekit-rtc/livekit/rtc/__init__.py
index 8b3e7729..20378bb9 100644
--- a/livekit-rtc/livekit/rtc/__init__.py
+++ b/livekit-rtc/livekit/rtc/__init__.py
@@ -12,7 +12,11 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-"""LiveKit RTC SDK"""
+"""LiveKit SDK for Python
+`pip install livekit`
+
+See https://docs.livekit.io/home/client/connect/#installing-the-livekit-sdk for more information.
+"""
 
 from ._proto import stats_pb2 as stats
 from ._proto.e2ee_pb2 import EncryptionState, EncryptionType