fix: update broken method calls (#203)

supabase · Sep 25, 2024 · b162e00 · b162e00
1 parent 2ce6efb
commit b162e00
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/realtime/_async/channel.py b/realtime/_async/channel.py
@@ -95,7 +95,7 @@ def on_close(*args):
             logging.info(f"channel {self.topic} closed")
             self.rejoin_timer.reset()
             self.state = ChannelStates.CLOSED
-            self.socket._remove(self)
+            self.socket.remove_channel(self)
 
         def on_error(payload, *args):
             if self.is_leaving or self.is_closed:
@@ -290,11 +290,11 @@ async def join(self) -> AsyncRealtimeChannel:
         :return: Channel
         """
         try:
-            await self.socket._send(
+            await self.socket.send(
                 {
                     "topic": self.topic,
                     "event": "phx_join",
-                    "payload": {"config": self.channel_params},
+                    "payload": {"config": self.params},
                     "ref": None,
                 }
             )

diff --git a/realtime/_async/client.py b/realtime/_async/client.py
@@ -94,7 +94,7 @@ async def _listen(self) -> None:
             except websockets.exceptions.ConnectionClosed:
                 if self.auto_reconnect:
                     logger.info("Connection with server closed, trying to reconnect...")
-                    await self._connect()
+                    await self.connect()
                     for topic, channel in self.channels.items():
                         await channel.join()
                 else:
@@ -190,7 +190,7 @@ async def _heartbeat(self) -> None:
             except websockets.exceptions.ConnectionClosed:
                 if self.auto_reconnect:
                     logger.info("Connection with server closed, trying to reconnect...")
-                    await self._connect()
+                    await self.connect()
                 else:
                     logger.exception("Connection with the server closed.")
                     break