OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	05/09/2024 07:00:17 AM	rwxr-xr-x
📄 __init__.py	1.6 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 __main__.py	30 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📁 __pycache__	-	05/09/2024 07:00:16 AM	rwxr-xr-x
📄 _dist_ver.py	23 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _main.py	283 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _monitor.py	3.61 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 _tqdm.py	283 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _tqdm_gui.py	287 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _tqdm_notebook.py	307 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _tqdm_pandas.py	888 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 _utils.py	596 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 asyncio.py	2.72 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 auto.py	1.08 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 autonotebook.py	956 bytes	05/09/2024 07:00:16 AM	rw-r--r--
📄 cli.py	10.62 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 completion.sh	946 bytes	05/09/2024 07:00:16 AM	rwxr-xr-x
📁 contrib	-	05/09/2024 07:00:16 AM	rwxr-xr-x
📄 dask.py	1.34 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 gui.py	5.8 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 keras.py	4.31 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 notebook.py	11.05 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 rich.py	5.03 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 std.py	56.97 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 tk.py	6.79 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 tqdm.1	7.81 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 utils.py	9.57 KB	05/09/2024 07:00:16 AM	rw-r--r--
📄 version.py	333 bytes	05/09/2024 07:00:16 AM	rw-r--r--

Editing: asyncio.py

"""
Asynchronous progressbar decorator for iterators.
Includes a default `range` iterator printing to `stderr`.

Usage:
>>> from tqdm.asyncio import trange, tqdm
>>> async for i in trange(10):
...     ...
"""
import asyncio
from sys import version_info

from .std import tqdm as std_tqdm

__author__ = {"github.com/": ["casperdcl"]}
__all__ = ['tqdm_asyncio', 'tarange', 'tqdm', 'trange']

class tqdm_asyncio(std_tqdm):
    """
    Asynchronous-friendly version of tqdm (Python 3.6+).
    """
    def __init__(self, iterable=None, *args, **kwargs):
        super(tqdm_asyncio, self).__init__(iterable, *args, **kwargs)
        self.iterable_awaitable = False
        if iterable is not None:
            if hasattr(iterable, "__anext__"):
                self.iterable_next = iterable.__anext__
                self.iterable_awaitable = True
            elif hasattr(iterable, "__next__"):
                self.iterable_next = iterable.__next__
            else:
                self.iterable_iterator = iter(iterable)
                self.iterable_next = self.iterable_iterator.__next__

def __aiter__(self):
        return self

async def __anext__(self):
        try:
            if self.iterable_awaitable:
                res = await self.iterable_next()
            else:
                res = self.iterable_next()
            self.update()
            return res
        except StopIteration:
            self.close()
            raise StopAsyncIteration
        except BaseException:
            self.close()
            raise

def send(self, *args, **kwargs):
        return self.iterable.send(*args, **kwargs)

@classmethod
    def as_completed(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs):
        """
        Wrapper for `asyncio.as_completed`.
        """
        if total is None:
            total = len(fs)
        kwargs = {}
        if version_info[:2] < (3, 10):
            kwargs['loop'] = loop
        yield from cls(asyncio.as_completed(fs, timeout=timeout, **kwargs),
                       total=total, **tqdm_kwargs)

@classmethod
    async def gather(cls, *fs, loop=None, timeout=None, total=None, **tqdm_kwargs):
        """
        Wrapper for `asyncio.gather`.
        """
        async def wrap_awaitable(i, f):
            return i, await f

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):
    """
    A shortcut for `tqdm.asyncio.tqdm(range(*args), **kwargs)`.
    """
    return tqdm_asyncio(range(*args), **kwargs)

# Aliases
tqdm = tqdm_asyncio
trange = tarange