diff --git a/realtime/_async/channel.py b/realtime/_async/channel.py index 26e2b23..fa5d0fa 100644 --- a/realtime/_async/channel.py +++ b/realtime/_async/channel.py @@ -527,6 +527,6 @@ def _reply_event_name(self, ref: str): return f"chan_reply_{ref}" async def _rejoin_until_connected(self): - await self.rejoin_timer.schedule_timeout() + self.rejoin_timer.schedule_timeout() if self.socket.is_connected: await self._rejoin() diff --git a/realtime/_async/timer.py b/realtime/_async/timer.py index 26c2c91..34f0680 100644 --- a/realtime/_async/timer.py +++ b/realtime/_async/timer.py @@ -14,7 +14,7 @@ def reset(self): if self.timer: self.timer.cancel() - async def schedule_timeout(self): + def schedule_timeout(self): if self.timer: self.timer.cancel()