asyncio.run_coroutine_threadsafe(coro, loop) Submit a coroutine object to a given event loop.

partial Read bytes string before the end of stream was reached (

epoll.poll(timeout=-1, maxevents=-1) Wait for events. timeout in seconds (float)

pause_reading() Pause the receiving end of the transport. No data will be passed to the protocol’s data_received()

DatagramProtocol.datagram_received(data, addr) Called when a datagram is received. data is a bytes object containing

exception asyncio.InvalidStateError The operation is not allowed in this state.

kqueue.close() Close the control file descriptor of the kqueue object.

release() Release a semaphore, incrementing the internal counter by one. When it was zero on entry and another coroutine is

coroutine readuntil(separator=b'n') Read data from the stream until separator is found. On

class asyncio.Semaphore(value=1, *, loop=None) A Semaphore implementation. A semaphore manages