diff --git a/telethon/events/inlinequery.py b/telethon/events/inlinequery.py index 3eb503b1..8f6e4f54 100644 --- a/telethon/events/inlinequery.py +++ b/telethon/events/inlinequery.py @@ -187,6 +187,6 @@ class InlineQuery(EventBuilder): if inspect.isawaitable(obj): return obj - f = asyncio.Future(loop=loop) + f = loop.create_future() f.set_result(obj) return f diff --git a/telethon/network/mtprotosender.py b/telethon/network/mtprotosender.py index 44bd4c75..15f459d9 100644 --- a/telethon/network/mtprotosender.py +++ b/telethon/network/mtprotosender.py @@ -282,7 +282,7 @@ class MTProtoSender: # First connection or manual reconnection after a failure if self._disconnected is None or self._disconnected.done(): - self._disconnected = asyncio.Future(loop=self._loop) + self._disconnected = self._loop.create_future() __log__.info('Connection to {} complete!'.format(self._ip)) async def _reconnect(self): diff --git a/telethon/tl/core/tlmessage.py b/telethon/tl/core/tlmessage.py index 406632db..60653e32 100644 --- a/telethon/tl/core/tlmessage.py +++ b/telethon/tl/core/tlmessage.py @@ -30,7 +30,7 @@ class TLMessage(TLObject): # If no loop is given then it is an incoming message. # Only outgoing messages need the future to await them. - self.future = asyncio.Future(loop=loop) if loop else None + self.future = loop.create_future() if loop else None # After which message ID this one should run. We do this so # InvokeAfterMsgRequest is transparent to the user and we can diff --git a/telethon/tl/custom/conversation.py b/telethon/tl/custom/conversation.py index c6c00bf9..f8d9cc5b 100644 --- a/telethon/tl/custom/conversation.py +++ b/telethon/tl/custom/conversation.py @@ -181,7 +181,7 @@ class Conversation(ChatGetter): return incoming # Otherwise the next incoming response will be the one to use - future = asyncio.Future(loop=self._client.loop) + future = self._client.loop.create_future() pending[target_id] = future return self._get_result(future, start_time, timeout) @@ -220,7 +220,7 @@ class Conversation(ChatGetter): will also trigger even without a response. """ start_time = time.time() - future = asyncio.Future(loop=self._client.loop) + future = self._client.loop.create_future() target_id = self._get_message_id(message) if self._last_read is None: