asyncio.Protocol.data_received()

Protocol.data_received(data) Called when some data is received. data is a non-empty bytes object containing the incoming data. Note Whether the data is buffered, chunked or reassembled depends on the transport. In general, you shouldn’t rely on specific semantics and instead make your parsing generic and flexible enough. However, data is always received in the correct order.

asyncio.Protocol

class asyncio.Protocol The base class for implementing streaming protocols (for use with e.g. TCP and SSL transports).

asyncio.ProactorEventLoop

class asyncio.ProactorEventLoop Proactor event loop for Windows using “I/O Completion Ports” aka IOCP. Subclass of AbstractEventLoop. Availability: Windows. See also MSDN documentation on I/O Completion Ports.

asyncio.PriorityQueue

class asyncio.PriorityQueue A subclass of Queue; retrieves entries in priority order (lowest first). Entries are typically tuples of the form: (priority number, data).

asyncio.open_unix_connection()

coroutine asyncio.open_unix_connection(path=None, *, loop=None, limit=None, **kwds) A wrapper for create_unix_connection() returning a (reader, writer) pair. See open_connection() for information about return value and other details. This function is a coroutine. Availability: UNIX.

asyncio.open_connection()

coroutine asyncio.open_connection(host=None, port=None, *, loop=None, limit=None, **kwds) A wrapper for create_connection() returning a (reader, writer) pair. The reader returned is a StreamReader instance; the writer is a StreamWriter instance. The arguments are all the usual arguments to AbstractEventLoop.create_connection() except protocol_factory; most common are positional host and port, with various optional keyword arguments following. Additional optional keyword arguments are loop (t

asyncio.new_event_loop()

asyncio.new_event_loop() Equivalent to calling get_event_loop_policy().new_event_loop().

asyncio.Lock.release()

release() Release a lock. When the lock is locked, reset it to unlocked, and return. If any other coroutines are blocked waiting for the lock to become unlocked, allow exactly one of them to proceed. When invoked on an unlocked lock, a RuntimeError is raised. There is no return value.

asyncio.Lock.locked()

locked() Return True if the lock is acquired.

asyncio.Lock.acquire()

coroutine acquire() Acquire a lock. This method blocks until the lock is unlocked, then sets it to locked and returns True. This method is a coroutine.