Don't break existing references to connection_dropped

This commit is contained in:
Dan Elkouby 2018-06-17 18:57:46 +03:00
parent 47fc91ccd0
commit d9b8c1b0be

View File

@ -261,7 +261,9 @@ class MTProtoSender:
__log__.debug('Starting receive loop') __log__.debug('Starting receive loop')
self._recv_loop_handle = self._loop.create_task(self._recv_loop()) self._recv_loop_handle = self._loop.create_task(self._recv_loop())
self._connection_dropped = asyncio.Future() # First connection or manual reconnection after a failure
if self._connection_dropped is None or self._connection_dropped.done():
self._connection_dropped = asyncio.Future()
__log__.info('Connection to {} complete!'.format(self._ip)) __log__.info('Connection to {} complete!'.format(self._ip))
async def _reconnect(self): async def _reconnect(self):