|
@@ -519,9 +519,6 @@ class ChattoAdapter(BasePlatformAdapter):
|
|
|
stream_events() which provides pre-decoded RealtimeEvent objects.
|
|
stream_events() which provides pre-decoded RealtimeEvent objects.
|
|
|
"""
|
|
"""
|
|
|
|
|
|
|
|
- # Ensure ws_ready is available for synchronization with starter
|
|
|
|
|
- backoff = ChattoConstants.WS_RECONNECT_INITIAL_BACKOFF
|
|
|
|
|
-
|
|
|
|
|
delay = ChattoConstants.WS_RECONNECT_INITIAL_BACKOFF
|
|
delay = ChattoConstants.WS_RECONNECT_INITIAL_BACKOFF
|
|
|
while not self._closing:
|
|
while not self._closing:
|
|
|
try:
|
|
try:
|
|
@@ -575,8 +572,6 @@ class ChattoAdapter(BasePlatformAdapter):
|
|
|
await self._sleep_interruptible(delay + jitter)
|
|
await self._sleep_interruptible(delay + jitter)
|
|
|
delay = min(delay * 2, ChattoConstants.WS_RECONNECT_MAX_BACKOFF)
|
|
delay = min(delay * 2, ChattoConstants.WS_RECONNECT_MAX_BACKOFF)
|
|
|
|
|
|
|
|
- await asyncio.sleep(backoff)
|
|
|
|
|
-
|
|
|
|
|
|
|
|
|
|
async def _sleep_interruptible(self, seconds: float) -> None:
|
|
async def _sleep_interruptible(self, seconds: float) -> None:
|
|
|
"""Sleep in short slices so disconnect() cancels promptly."""
|
|
"""Sleep in short slices so disconnect() cancels promptly."""
|