Use inspect's iscoroutinefunction, not asyncio's

delivrance · delivrance · commit 65b5229fe8c9 · 2020-08-25T09:32:39.000+02:00
diff --git a/pyrogram/client.py b/pyrogram/client.py
@@ -18,6 +18,7 @@
 
 import asyncio
 import functools
+import inspect
 import logging
 import os
 import re
@@ -1025,7 +1026,7 @@ async def get_file(
                             offset += limit
 
                             if progress:
-                                if asyncio.iscoroutinefunction(progress):
+                                if inspect.iscoroutinefunction(progress):
                                     await progress(
                                         min(offset, file_size) if file_size != 0 else offset,
                                         file_size,
diff --git a/pyrogram/dispatcher.py b/pyrogram/dispatcher.py
@@ -17,6 +17,7 @@
 #  along with Pyrogram.  If not, see <http://www.gnu.org/licenses/>.
 
 import asyncio
+import inspect
 import logging
 from collections import OrderedDict
 
@@ -203,7 +204,7 @@ async def handler_worker(self, lock):
                                 continue
 
                             try:
-                                if asyncio.iscoroutinefunction(handler.callback):
+                                if inspect.iscoroutinefunction(handler.callback):
                                     await handler.callback(self.client, *args)
                                 else:
                                     await self.loop.run_in_executor(
diff --git a/pyrogram/methods/advanced/save_file.py b/pyrogram/methods/advanced/save_file.py
@@ -18,6 +18,7 @@
 
 import asyncio
 import functools
+import inspect
 import io
 import logging
 import math
@@ -182,7 +183,7 @@ async def worker(session):
                     file_part += 1
 
                     if progress:
-                        if asyncio.iscoroutinefunction(progress):
+                        if inspect.iscoroutinefunction(progress):
                             await progress(min(file_part * part_size, file_size), file_size, *progress_args)
                         else:
                             func = functools.partial(
