Refactoring CartesiaSTT to use request to reconnect.
This commit is contained in:
@@ -323,9 +323,7 @@ class CartesiaSTTService(WebsocketSTTService):
|
|||||||
if not changed:
|
if not changed:
|
||||||
return changed
|
return changed
|
||||||
|
|
||||||
if self._websocket:
|
await self._request_reconnect()
|
||||||
await self._disconnect()
|
|
||||||
await self._connect()
|
|
||||||
|
|
||||||
return changed
|
return changed
|
||||||
|
|
||||||
|
|||||||
@@ -626,6 +626,7 @@ class STTService(AIService):
|
|||||||
schedules a reconnect that fires as soon as ``UserStoppedSpeakingFrame``
|
schedules a reconnect that fires as soon as ``UserStoppedSpeakingFrame``
|
||||||
is received.
|
is received.
|
||||||
"""
|
"""
|
||||||
|
logger.debug(f"{self} requesting to reconnect!")
|
||||||
if self._can_reconnect:
|
if self._can_reconnect:
|
||||||
await self._reconnect()
|
await self._reconnect()
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user