asyncio: fix, tidy & update gather & tests

tests/py37_asyncio.py

@@ -115,20 +115,14 @@ async def test_as_completed(capsys, tol):
                 raise
 
 
-@mark.slow
+async def double(i):
+    return i * 2
+
+
 @mark.asyncio
-@mark.parametrize("tol", [0.2 if platform.startswith("darwin") else 0.1])
-async def test_gather(capsys, tol):
+async def test_gather(capsys):
     """Test asyncio gather"""
-    for retry in range(3):
-        t = time()
-        skew = time() - t
-        await gather([asyncio.sleep(0.01 * i) for i in range(30, 0, -1)])
-        t = time() - t - 2 * skew
-        try:
-            assert 0.3 * (1 - tol) < t < 0.3 * (1 + tol), t
-            _, err = capsys.readouterr()
-            assert '30/30' in err
-        except AssertionError:
-            if retry == 2:
-                raise
+    res = await gather(list(map(double, range(30))))
+    _, err = capsys.readouterr()
+    assert '30/30' in err
+    assert res == list(range(0, 30 * 2, 2))

tqdm/asyncio.py

@@ -8,15 +8,12 @@
 ...     ...
 """
 import asyncio
-from typing import Awaitable, List, TypeVar
 
 from .std import tqdm as std_tqdm
 
 __author__ = {"github.com/": ["casperdcl"]}
 __all__ = ['tqdm_asyncio', 'tarange', 'tqdm', 'trange']
 
-T = TypeVar("T")
-
 
 class tqdm_asyncio(std_tqdm):
     """
@@ -67,38 +64,17 @@ def as_completed(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs)
                        total=total, **tqdm_kwargs)
 
     @classmethod
-    async def gather(
-            cls,
-            fs: List[Awaitable[T]],
-            *,
-            loop=None,
-            timeout=None,
-            total=None,
-            **tqdm_kwargs
-    ) -> List[T]:
+    async def gather(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs):
         """
-        Re-creating the functionality of asyncio.gather, giving a progress bar like
-        tqdm.as_completed(), but returning the results in original order.
+        Wrapper for `asyncio.gather`.
         """
-        async def wrap_awaitable(number: int, awaitable: Awaitable[T]):
-            return number, await awaitable
-        if total is None:
-            total = len(fs)
-
-        numbered_awaitables = [wrap_awaitable(idx, fs[idx]) for idx in range(len(fs))]
-
-        numbered_results = [
-            await f for f in cls.as_completed(
-                numbered_awaitables,
-                total=total,
-                loop=loop,
-                timeout=timeout,
-                **tqdm_kwargs
-            )
-        ]
+        async def wrap_awaitable(i, f):
+            return i, await f
 
-        results = [result_tuple[1] for result_tuple in sorted(numbered_results)]
-        return results
+        ifs = [wrap_awaitable(i, f) for i, f in enumerate(fs)]
+        res = [await f for f in cls.as_completed(ifs, loop=loop, timeout=timeout,
+                                                 total=total, **tqdm_kwargs)]
+        return [i for _, i in sorted(res)]
 
 
 def tarange(*args, **kwargs):