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 @@ -733,7 +733,7 @@ async def reset(self):
733
733
async with self ._lock :
734
734
if self .connection :
735
735
await self .connection .disconnect ()
736
- self .connection .deregister_connect_callback (self .on_connect )
736
+ self .connection ._deregister_connect_callback (self .on_connect )
737
737
await self .connection_pool .release (self .connection )
738
738
self .connection = None
739
739
self .channels = {}
@@ -794,7 +794,7 @@ async def connect(self):
794
794
)
795
795
# register a callback that re-subscribes to any channels we
796
796
# were listening to when we were disconnected
797
- self .connection .register_connect_callback (self .on_connect )
797
+ self .connection ._register_connect_callback (self .on_connect )
798
798
else :
799
799
await self .connection .connect ()
800
800
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):
216
216
def is_connected (self ):
217
217
return self ._reader is not None and self ._writer is not None
218
218
219
- def register_connect_callback (self , callback ):
219
+ def _register_connect_callback (self , callback ):
220
220
wm = weakref .WeakMethod (callback )
221
221
if wm not in self ._connect_callbacks :
222
222
self ._connect_callbacks .append (wm )
223
223
224
- def deregister_connect_callback (self , callback ):
224
+ def _deregister_connect_callback (self , callback ):
225
225
try :
226
226
self ._connect_callbacks .remove (weakref .WeakMethod (callback ))
227
227
except ValueError :
You can’t perform that action at this time.
0 commit comments