FM / asyncio

/usr/lib64/python3.9/asyncio

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
base_events.py	74192	0644	edit dl rm
base_futures.py	2574	0644	edit dl rm
base_subprocess.py	8843	0644	edit dl rm
base_tasks.py	2467	0644	edit dl rm
constants.py	888	0644	edit dl rm
coroutines.py	8797	0644	edit dl rm
events.py	26451	0644	edit dl rm
exceptions.py	1633	0644	edit dl rm
format_helpers.py	2404	0644	edit dl rm
futures.py	14042	0644	edit dl rm
locks.py	15181	0644	edit dl rm
log.py	124	0644	edit dl rm
proactor_events.py	32146	0644	edit dl rm
protocols.py	6957	0644	edit dl rm
queues.py	8305	0644	edit dl rm
runners.py	2125	0644	edit dl rm
selector_events.py	39500	0644	edit dl rm
sslproto.py	27459	0644	edit dl rm
staggered.py	5992	0644	edit dl rm
streams.py	26656	0644	edit dl rm
subprocess.py	8070	0644	edit dl rm
tasks.py	34419	0644	edit dl rm
threads.py	790	0644	edit dl rm
transports.py	10724	0644	edit dl rm
trsock.py	5876	0644	edit dl rm
unix_events.py	51754	0644	edit dl rm
windows_events.py	33054	0644	edit dl rm
windows_utils.py	5060	0644	edit dl rm
__init__.py	1279	0644	edit dl rm
__main__.py	3379	0644	edit dl rm

Edit: /usr/lib64/python3.9/asyncio/exceptions.py (1633B)

"""asyncio exceptions."""

__all__ = ('CancelledError', 'InvalidStateError', 'TimeoutError',
           'IncompleteReadError', 'LimitOverrunError',
           'SendfileNotAvailableError')

class CancelledError(BaseException):
    """The Future or Task was cancelled."""

class TimeoutError(Exception):
    """The operation exceeded the given deadline."""

class InvalidStateError(Exception):
    """The operation is not allowed in this state."""

class SendfileNotAvailableError(RuntimeError):
    """Sendfile syscall is not available.

Raised if OS does not support sendfile syscall for given socket or
    file type.
    """

class IncompleteReadError(EOFError):
    """
    Incomplete read error. Attributes:

- partial: read bytes string before the end of stream was reached
    - expected: total number of expected bytes (or None if unknown)
    """
    def __init__(self, partial, expected):
        r_expected = 'undefined' if expected is None else repr(expected)
        super().__init__(f'{len(partial)} bytes read on a total of '
                         f'{r_expected} expected bytes')
        self.partial = partial
        self.expected = expected

def __reduce__(self):
        return type(self), (self.partial, self.expected)

class LimitOverrunError(Exception):
    """Reached the buffer limit while looking for a separator.

Attributes:
    - consumed: total number of to be consumed bytes.
    """
    def __init__(self, message, consumed):
        super().__init__(message)
        self.consumed = consumed

def __reduce__(self):
        return type(self), (self.args[0], self.consumed)

"""asyncio exceptions.""" __all__ = ('CancelledError', 'InvalidStateError', 'TimeoutError', 'IncompleteReadError', 'LimitOverrunError', 'SendfileNotAvailableError') class CancelledError(BaseException): """The Future or Task was cancelled.""" class TimeoutError(Exception): """The operation exceeded the given deadline.""" class InvalidStateError(Exception): """The operation is not allowed in this state.""" class SendfileNotAvailableError(RuntimeError): """Sendfile syscall is not available. Raised if OS does not support sendfile syscall for given socket or file type. """ class IncompleteReadError(EOFError): """ Incomplete read error. Attributes: - partial: read bytes string before the end of stream was reached - expected: total number of expected bytes (or None if unknown) """ def __init__(self, partial, expected): r_expected = 'undefined' if expected is None else repr(expected) super().__init__(f'{len(partial)} bytes read on a total of ' f'{r_expected} expected bytes') self.partial = partial self.expected = expected def __reduce__(self): return type(self), (self.partial, self.expected) class LimitOverrunError(Exception): """Reached the buffer limit while looking for a separator. Attributes: - consumed: total number of to be consumed bytes. """ def __init__(self, message, consumed): super().__init__(message) self.consumed = consumed def __reduce__(self): return type(self), (self.args[0], self.consumed)