usr
/
lib64
/
python3.6
/
asyncio
/
Go to Home Directory
+
Upload
Create File
root@0UT1S:~$
Execute
By Order of Mr.0UT1S
[DIR] ..
N/A
[DIR] __pycache__
N/A
__init__.py
1.40 KB
Rename
Delete
base_events.py
56.00 KB
Rename
Delete
base_futures.py
2.03 KB
Rename
Delete
base_subprocess.py
8.88 KB
Rename
Delete
base_tasks.py
2.13 KB
Rename
Delete
compat.py
543 bytes
Rename
Delete
constants.py
371 bytes
Rename
Delete
coroutines.py
10.87 KB
Rename
Delete
events.py
22.96 KB
Rename
Delete
futures.py
15.53 KB
Rename
Delete
locks.py
15.22 KB
Rename
Delete
log.py
124 bytes
Rename
Delete
proactor_events.py
19.92 KB
Rename
Delete
protocols.py
4.41 KB
Rename
Delete
queues.py
7.77 KB
Rename
Delete
selector_events.py
40.66 KB
Rename
Delete
sslproto.py
25.40 KB
Rename
Delete
streams.py
23.90 KB
Rename
Delete
subprocess.py
7.45 KB
Rename
Delete
tasks.py
24.47 KB
Rename
Delete
test_utils.py
14.74 KB
Rename
Delete
transports.py
9.83 KB
Rename
Delete
unix_events.py
36.39 KB
Rename
Delete
windows_events.py
27.18 KB
Rename
Delete
windows_utils.py
6.72 KB
Rename
Delete
__all__ = [] import concurrent.futures._base import reprlib from . import events Error = concurrent.futures._base.Error CancelledError = concurrent.futures.CancelledError TimeoutError = concurrent.futures.TimeoutError class InvalidStateError(Error): """The operation is not allowed in this state.""" # States for Future. _PENDING = 'PENDING' _CANCELLED = 'CANCELLED' _FINISHED = 'FINISHED' def isfuture(obj): """Check for a Future. This returns True when obj is a Future instance or is advertising itself as duck-type compatible by setting _asyncio_future_blocking. See comment in Future for more details. """ return (hasattr(obj.__class__, '_asyncio_future_blocking') and obj._asyncio_future_blocking is not None) def _format_callbacks(cb): """helper function for Future.__repr__""" size = len(cb) if not size: cb = '' def format_cb(callback): return events._format_callback_source(callback, ()) if size == 1: cb = format_cb(cb[0]) elif size == 2: cb = '{}, {}'.format(format_cb(cb[0]), format_cb(cb[1])) elif size > 2: cb = '{}, <{} more>, {}'.format(format_cb(cb[0]), size - 2, format_cb(cb[-1])) return 'cb=[%s]' % cb def _future_repr_info(future): # (Future) -> str """helper function for Future.__repr__""" info = [future._state.lower()] if future._state == _FINISHED: if future._exception is not None: info.append('exception={!r}'.format(future._exception)) else: # use reprlib to limit the length of the output, especially # for very long strings result = reprlib.repr(future._result) info.append('result={}'.format(result)) if future._callbacks: info.append(_format_callbacks(future._callbacks)) if future._source_traceback: frame = future._source_traceback[-1] info.append('created at %s:%s' % (frame[0], frame[1])) return info
Save