golden hour

/opt/alt/python37/lib64/python3.7/site-packages/aiohttp

File/Folder	Size	Actions
.hash	-
__init__.py	6.71 KB
__pycache__	-
_cparser.pxd	4.88 KB
_find_header.c	183.17 KB
_find_header.h	170 B
_find_header.pxd	68 B
_headers.pxi	1.96 KB
_helpers.c	207.99 KB
_helpers.cpython-37m-x86_64-linux-gnu.so	207.44 KB
_helpers.pyi	202 B
_helpers.pyx	1.02 KB
_http_parser.c	955.26 KB
_http_parser.cpython-37m-x86_64-linux-gnu.so	1.56 MB
_http_parser.pyx	25.95 KB
_http_writer.c	216.08 KB
_http_writer.cpython-37m-x86_64-linux-gnu.so	196.02 KB
_http_writer.pyx	4.47 KB
_websocket.c	135.18 KB
_websocket.cpython-37m-x86_64-linux-gnu.so	95.97 KB
_websocket.pyx	1.52 KB
abc.py	5.38 KB
base_protocol.py	2.64 KB
client.py	43.87 KB
client_exceptions.py	9.06 KB
client_proto.py	8 KB
client_reqrep.py	36.02 KB
client_ws.py	10.29 KB
connector.py	49.66 KB
cookiejar.py	13.25 KB
formdata.py	5.98 KB
hdrs.py	4.61 KB
helpers.py	25.63 KB
http.py	1.78 KB
http_exceptions.py	2.53 KB
http_parser.py	31.83 KB
http_websocket.py	24.76 KB
http_writer.py	5.84 KB
locks.py	1.13 KB
log.py	325 B
multipart.py	31.68 KB
payload.py	13.38 KB
payload_streamer.py	2.06 KB
py.typed	7 B
pytest_plugin.py	11.5 KB
resolver.py	4.97 KB
streams.py	20.35 KB
tcp_helpers.py	962 B
test_utils.py	20.72 KB
tracing.py	14.95 KB
typedefs.py	1.72 KB
web.py	17.51 KB
web_app.py	16.86 KB
web_exceptions.py	9.87 KB
web_fileresponse.py	10.53 KB
web_log.py	7.39 KB
web_middlewares.py	4.04 KB
web_protocol.py	22.02 KB
web_request.py	27.23 KB
web_response.py	26.92 KB
web_routedef.py	5.9 KB
web_runner.py	10.93 KB
web_server.py	2.01 KB
web_urldispatcher.py	38.62 KB
web_ws.py	16.85 KB
worker.py	8.57 KB

Edit: locks.py

import asyncio
import collections
from typing import Any, Deque, Optional

class EventResultOrError:
    """Event asyncio lock helper class.

Wraps the Event asyncio lock allowing either to awake the
    locked Tasks without any error or raising an exception.

thanks to @vorpalsmith for the simple design.
    """

def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
        self._loop = loop
        self._exc = None  # type: Optional[BaseException]
        self._event = asyncio.Event()
        self._waiters = collections.deque()  # type: Deque[asyncio.Future[Any]]

def set(self, exc: Optional[BaseException] = None) -> None:
        self._exc = exc
        self._event.set()

async def wait(self) -> Any:
        waiter = self._loop.create_task(self._event.wait())
        self._waiters.append(waiter)
        try:
            val = await waiter
        finally:
            self._waiters.remove(waiter)

if self._exc is not None:
            raise self._exc

return val

def cancel(self) -> None:
        """Cancel all waiters"""
        for waiter in self._waiters:
            waiter.cancel()