File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -40,17 +40,22 @@ def set_close_callback(self, callback):
4040 self ._close_callback = callback
4141
4242 def stream_close_callback (self ):
43+ if self ._close_callback and callable (self ._close_callback ):
44+ cb = self ._close_callback
45+ self ._close_callback = None
46+ cb ()
47+
4348 if self .socket :
44- if self ._close_callback and callable (self ._close_callback ):
45- self ._close_callback ()
4649 sock = self .socket
4750 self .socket = None
4851 self ._rfile = None
4952 sock .set_close_callback (None )
5053
5154 def close (self ):
5255 if self ._close_callback and callable (self ._close_callback ):
53- self ._close_callback ()
56+ cb = self ._close_callback
57+ self ._close_callback = None
58+ cb ()
5459
5560 if self .socket is None :
5661 raise err .Error ("Already closed" )
You can’t perform that action at this time.
0 commit comments