RTVIProcessor: remove unused code
This commit is contained in:
@@ -639,8 +639,6 @@ class RTVIProcessor(FrameProcessor):
|
|||||||
super().__init__(**kwargs)
|
super().__init__(**kwargs)
|
||||||
self._config = config
|
self._config = config
|
||||||
|
|
||||||
self._pipeline: Optional[FrameProcessor] = None
|
|
||||||
|
|
||||||
self._bot_ready = False
|
self._bot_ready = False
|
||||||
self._client_ready = False
|
self._client_ready = False
|
||||||
self._client_ready_id = ""
|
self._client_ready_id = ""
|
||||||
@@ -754,11 +752,6 @@ class RTVIProcessor(FrameProcessor):
|
|||||||
else:
|
else:
|
||||||
await self.push_frame(frame, direction)
|
await self.push_frame(frame, direction)
|
||||||
|
|
||||||
async def cleanup(self):
|
|
||||||
await super().cleanup()
|
|
||||||
if self._pipeline:
|
|
||||||
await self._pipeline.cleanup()
|
|
||||||
|
|
||||||
async def _start(self, frame: StartFrame):
|
async def _start(self, frame: StartFrame):
|
||||||
if not self._action_task:
|
if not self._action_task:
|
||||||
self._action_task = self.create_task(self._action_task_handler())
|
self._action_task = self.create_task(self._action_task_handler())
|
||||||
|
|||||||
Reference in New Issue
Block a user