OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	10/07/2020 06:14:10 AM	rwxr-xr-x
📄 __init__.py	1.02 KB	04/25/2017 11:28:36 AM	rw-r--r--
📁 __pycache__	-	10/07/2020 06:14:11 AM	rwxr-xr-x
📄 connection.py	4.14 KB	06/08/2017 08:15:41 AM	rw-r--r--
📄 request.py	3.61 KB	10/01/2020 06:00:15 PM	rw-r--r--
📄 response.py	2.28 KB	10/01/2020 06:00:15 PM	rw-r--r--
📄 retry.py	14.73 KB	10/01/2020 06:00:15 PM	rw-r--r--
📄 selectors.py	20.65 KB	04/25/2017 11:10:19 AM	rw-r--r--
📄 ssl_.py	12.03 KB	10/01/2020 06:00:15 PM	rw-r--r--
📄 timeout.py	9.53 KB	01/19/2017 09:51:46 AM	rw-r--r--
📄 url.py	6.63 KB	10/01/2020 06:00:15 PM	rw-r--r--
📄 wait.py	1.42 KB	01/19/2017 09:51:46 AM	rw-r--r--

Editing: wait.py

from .selectors import (
    HAS_SELECT,
    DefaultSelector,
    EVENT_READ,
    EVENT_WRITE
)

def _wait_for_io_events(socks, events, timeout=None):
    """ Waits for IO events to be available from a list of sockets
    or optionally a single socket if passed in. Returns a list of
    sockets that can be interacted with immediately. """
    if not HAS_SELECT:
        raise ValueError('Platform does not have a selector')
    if not isinstance(socks, list):
        # Probably just a single socket.
        if hasattr(socks, "fileno"):
            socks = [socks]
        # Otherwise it might be a non-list iterable.
        else:
            socks = list(socks)
    with DefaultSelector() as selector:
        for sock in socks:
            selector.register(sock, events)
        return [key[0].fileobj for key in
                selector.select(timeout) if key[1] & events]

def wait_for_read(socks, timeout=None):
    """ Waits for reading to be available from a list of sockets
    or optionally a single socket if passed in. Returns a list of
    sockets that can be read from immediately. """
    return _wait_for_io_events(socks, EVENT_READ, timeout)

def wait_for_write(socks, timeout=None):
    """ Waits for writing to be available from a list of sockets
    or optionally a single socket if passed in. Returns a list of
    sockets that can be written to immediately. """
    return _wait_for_io_events(socks, EVENT_WRITE, timeout)