wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix up some class variable names

Browse Source
This commit is contained in:
Moishe Lettvin
2024-01-26 15:15:44 -05:00
parent d4c4d49035
commit 5d9aa530e2
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/dailyai/services/daily_transport_service.py
View File

@@ -126,8 +126,8 @@ class DailyTransportService(EventHandler):
if event_name not in [method[0] for method in methods]: if event_name not in [method[0] for method in methods]:
raise Exception(f"Event handler {event_name} not found") raise Exception(f"Event handler {event_name} not found")
if event_name not in self.event_handlers: if event_name not in self._event_handlers:
self.event_handlers[event_name] = [ self._event_handlers[event_name] = [
getattr( getattr(
self, event_name), types.MethodType( self, event_name), types.MethodType(
handler, self)] handler, self)]
@@ -232,7 +232,7 @@ class DailyTransportService(EventHandler):
asyncio.run_coroutine_threadsafe(self.receive_queue.put(frame), self._loop) asyncio.run_coroutine_threadsafe(self.receive_queue.put(frame), self._loop)
def interrupt(self): def interrupt(self):
self.is_interrupted.set() self._is_interrupted.set()
async def get_receive_frames(self) -> AsyncGenerator[QueueFrame, None]: async def get_receive_frames(self) -> AsyncGenerator[QueueFrame, None]:
while True: while True:
@@ -292,7 +292,7 @@ class DailyTransportService(EventHandler):
def stop(self): def stop(self):
self._stop_threads.set() self._stop_threads.set()
def _on_first_other_participant_joined(self): def on_first_other_participant_joined(self):
pass pass
def call_joined(self, join_data, client_error): def call_joined(self, join_data, client_error):
@@ -310,7 +310,7 @@ class DailyTransportService(EventHandler):
def on_participant_joined(self, participant): def on_participant_joined(self, participant):
if not self._other_participant_has_joined and participant["id"] != self.my_participant_id: if not self._other_participant_has_joined and participant["id"] != self.my_participant_id:
self._other_participant_has_joined = True self._other_participant_has_joined = True
self._on_first_other_participant_joined() self.on_first_other_participant_joined()
def on_participant_left(self, participant, reason): def on_participant_left(self, participant, reason):
if len(self.client.participants()) < self.min_others_count + 1: if len(self.client.participants()) < self.min_others_count + 1:
@@ -408,7 +408,7 @@ class DailyTransportService(EventHandler):
if len(b): if len(b):
self.mic.write_frames(bytes(b)) self.mic.write_frames(bytes(b))
except Exception as e: except Exception as e:
self.logger.error(f"Exception in frame_consumer: {e}, {len(b)}") self._logger.error(f"Exception in frame_consumer: {e}, {len(b)}")
raise e raise e
b = bytearray() b = bytearray()