Na}{

File Content: `locks.py`

import asyncio
import collections


class EventResultOrError:
    """
    This class wrappers the Event asyncio lock allowing either awake the
    locked Tasks without any error or raising an exception.

    thanks to @vorpalsmith for the simple design.
    """
    def __init__(self, loop):
        self._loop = loop
        self._exc = None
        self._event = asyncio.Event(loop=loop)
        self._waiters = collections.deque()

    def set(self, exc=None):
        self._exc = exc
        self._event.set()

    async def wait(self):
        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):
        """ Cancel all waiters """
        for waiter in self._waiters:
            waiter.cancel()

Name	Size	Permission
__pycache__	---	0755
__init__.py	1383 bytes	0644
_cparser.pxd	3959 bytes	0644
_frozenlist.c	285743 bytes	0644
_frozenlist.cpython-35m-x86_64-linux-gnu.so	65264 bytes	0755
_frozenlist.pyx	2605 bytes	0644
_http_parser.c	606338 bytes	0644
_http_parser.cpython-35m-x86_64-linux-gnu.so	159056 bytes	0755
_http_parser.pyx	21093 bytes	0644
_websocket.c	128346 bytes	0644
_websocket.cpython-35m-x86_64-linux-gnu.so	24968 bytes	0755
_websocket.pyx	1560 bytes	0644
abc.py	3390 bytes	0644
client.py	32576 bytes	0644
client_exceptions.py	5404 bytes	0644
client_proto.py	5879 bytes	0644
client_reqrep.py	28617 bytes	0644
client_ws.py	8894 bytes	0644
connector.py	32578 bytes	0644
cookiejar.py	10234 bytes	0644
formdata.py	5344 bytes	0644
frozenlist.py	1773 bytes	0644
hdrs.py	3359 bytes	0644
helpers.py	22894 bytes	0644
http.py	1294 bytes	0644
http_exceptions.py	1973 bytes	0644
http_parser.py	24343 bytes	0644
http_websocket.py	22001 bytes	0644
http_writer.py	4003 bytes	0644
locks.py	946 bytes	0644
log.py	326 bytes	0644
multipart.py	29580 bytes	0644
payload.py	8398 bytes	0644
payload_streamer.py	1530 bytes	0644
pytest_plugin.py	9773 bytes	0644
resolver.py	3312 bytes	0644
signals.py	933 bytes	0644
streams.py	16703 bytes	0644
tcp_helpers.py	1409 bytes	0644
test_utils.py	16126 bytes	0644
tracing.py	9542 bytes	0644
web.py	7194 bytes	0644
web_app.py	10119 bytes	0644
web_exceptions.py	8582 bytes	0644
web_fileresponse.py	7695 bytes	0644
web_middlewares.py	2659 bytes	0644
web_protocol.py	17987 bytes	0644
web_request.py	20915 bytes	0644
web_response.py	21476 bytes	0644
web_runner.py	8239 bytes	0644
web_server.py	1325 bytes	0644
web_urldispatcher.py	33458 bytes	0644
web_ws.py	14682 bytes	0644
worker.py	7087 bytes	0644

File Content: locks.py

File Content: `locks.py`