make connect callback methods internal

Author: kristjanvalur

redis/asyncio/client.py

@@ -792,7 +792,7 @@ async def aclose(self):
         async with self._lock:
             if self.connection:
                 await self.connection.disconnect()
-                self.connection.deregister_connect_callback(self.on_connect)
+                self.connection._deregister_connect_callback(self.on_connect)
                 await self.connection_pool.release(self.connection)
                 self.connection = None
             self.channels = {}
@@ -855,7 +855,7 @@ async def connect(self):
             )
             # register a callback that re-subscribes to any channels we
             # were listening to when we were disconnected
-            self.connection.register_connect_callback(self.on_connect)
+            self.connection._register_connect_callback(self.on_connect)
         else:
             await self.connection.connect()
         if self.push_handler_func is not None and not HIREDIS_AVAILABLE:

redis/asyncio/connection.py

@@ -216,12 +216,12 @@ def repr_pieces(self):
     def is_connected(self):
         return self._reader is not None and self._writer is not None
 
-    def register_connect_callback(self, callback):
+    def _register_connect_callback(self, callback):
         wm = weakref.WeakMethod(callback)
         if wm not in self._connect_callbacks:
             self._connect_callbacks.append(wm)
 
-    def deregister_connect_callback(self, callback):
+    def _deregister_connect_callback(self, callback):
         try:
             self._connect_callbacks.remove(weakref.WeakMethod(callback))
         except ValueError: