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

Denote a couple of variables are private with a leading underscore

Browse Source
This commit is contained in:
Paul Kompfner
2025-09-17 15:38:28 -04:00
parent a12392182c
commit 5b55988846
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/pipeline/service_switcher.py
View File

@@ -102,16 +102,16 @@ class ServiceSwitcher(ParallelPipeline, Generic[StrategyType]):
"""Initialize the service switcher filter with a strategy and direction.""" """Initialize the service switcher filter with a strategy and direction."""
async def filter(_: Frame) -> bool: async def filter(_: Frame) -> bool:
return self.wrapped_service == self.active_service return self._wrapped_service == self._active_service
super().__init__(filter, direction) super().__init__(filter, direction)
self.wrapped_service = wrapped_service self._wrapped_service = wrapped_service
self.active_service = active_service self._active_service = active_service
async def process_frame(self, frame, direction): async def process_frame(self, frame, direction):
"""Process a frame through the filter, handling special internal filter-updating frames.""" """Process a frame through the filter, handling special internal filter-updating frames."""
if isinstance(frame, ServiceSwitcher.ServiceSwitcherFilterFrame): if isinstance(frame, ServiceSwitcher.ServiceSwitcherFilterFrame):
self.active_service = frame.active_service self._active_service = frame.active_service
# Two ServiceSwitcherFilters "sandwich" a service. Push the # Two ServiceSwitcherFilters "sandwich" a service. Push the
# frame only to update the other side of the sandwich, but # frame only to update the other side of the sandwich, but
# otherwise don't let it leave the sandwich. # otherwise don't let it leave the sandwich.