File tree Expand file tree Collapse file tree 1 file changed +2
-13
lines changed
Expand file tree Collapse file tree 1 file changed +2
-13
lines changed Original file line number Diff line number Diff line change @@ -267,22 +267,11 @@ def close(self, reconnect: bool = False) -> None:
267267 self ._reconnect_task .cancel ()
268268 self ._reconnect_task = None
269269
270- if not reconnect :
270+ if not reconnect or not self . delay_ms :
271271 self .delay_ms = 0
272272 return
273273
274- self ._launch_reconnect ()
275-
276- def _launch_reconnect (self ):
277- """Launch delayed reconnection coroutine"""
278- if not self .delay_ms :
279- return
280- if self ._reconnect_task :
281- Log .warning (
282- "Ignoring launch of delayed reconnection, another is in progress"
283- )
284- else :
285- self ._reconnect_task = asyncio .create_task (self ._reconnect ())
274+ self ._reconnect_task = asyncio .create_task (self ._reconnect ())
286275
287276 async def _reconnect (self ):
288277 """Reconnect."""
You can’t perform that action at this time.
0 commit comments