File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -776,7 +776,7 @@ async def reset(self):
776776 async with self ._lock :
777777 if self .connection :
778778 await self .connection .disconnect ()
779- self .connection .deregister_connect_callback (self .on_connect )
779+ self .connection ._deregister_connect_callback (self .on_connect )
780780 await self .connection_pool .release (self .connection )
781781 self .connection = None
782782 self .channels = {}
@@ -837,7 +837,7 @@ async def connect(self):
837837 )
838838 # register a callback that re-subscribes to any channels we
839839 # were listening to when we were disconnected
840- self .connection .register_connect_callback (self .on_connect )
840+ self .connection ._register_connect_callback (self .on_connect )
841841 else :
842842 await self .connection .connect ()
843843 if self .push_handler_func is not None and not HIREDIS_AVAILABLE :
Original file line number Diff line number Diff line change @@ -216,12 +216,12 @@ def repr_pieces(self):
216216 def is_connected (self ):
217217 return self ._reader is not None and self ._writer is not None
218218
219- def register_connect_callback (self , callback ):
219+ def _register_connect_callback (self , callback ):
220220 wm = weakref .WeakMethod (callback )
221221 if wm not in self ._connect_callbacks :
222222 self ._connect_callbacks .append (wm )
223223
224- def deregister_connect_callback (self , callback ):
224+ def _deregister_connect_callback (self , callback ):
225225 try :
226226 self ._connect_callbacks .remove (weakref .WeakMethod (callback ))
227227 except ValueError :
You can’t perform that action at this time.
0 commit comments