File Manager

X7ROOT File Manager

Current Path: /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util

usr / lib / python2.7 / site-packages / pip / _vendor / urllib3 / util /

ðŸ“ ..
ðŸ“„ __init__.py(1.02 KB)
ðŸ“„ __init__.pyc(1.25 KB)
ðŸ“„ __init__.pyo(1.25 KB)
ðŸ“„ connection.py(4.14 KB)
ðŸ“„ connection.pyc(3.78 KB)
ðŸ“„ connection.pyo(3.78 KB)
ðŸ“„ request.py(3.62 KB)
ðŸ“„ request.pyc(3.67 KB)
ðŸ“„ request.pyo(3.67 KB)
ðŸ“„ response.py(2.29 KB)
ðŸ“„ response.pyc(2.24 KB)
ðŸ“„ response.pyo(2.24 KB)
ðŸ“„ retry.py(14.75 KB)
ðŸ“„ retry.pyc(14.38 KB)
ðŸ“„ retry.pyo(14.38 KB)
ðŸ“„ selectors.py(20.65 KB)
ðŸ“„ selectors.pyc(20.49 KB)
ðŸ“„ selectors.pyo(20.49 KB)
ðŸ“„ ssl_.py(11.93 KB)
ðŸ“„ ssl_.pyc(10.36 KB)
ðŸ“„ ssl_.pyo(10.36 KB)
ðŸ“„ timeout.py(9.53 KB)
ðŸ“„ timeout.pyc(9.49 KB)
ðŸ“„ timeout.pyo(9.49 KB)
ðŸ“„ url.py(6.64 KB)
ðŸ“„ url.pyc(6.61 KB)
ðŸ“„ url.pyo(6.61 KB)
ðŸ“„ wait.py(1.42 KB)
ðŸ“„ wait.pyc(1.8 KB)
ðŸ“„ wait.pyo(1.8 KB)

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)

X7ROOT File Manager

Editing: wait.py

Upload File

Create Folder