resume_reading() Resume the receiving end. The protocol’s data_received() method will be called once again if some data is available for reading.

coroutine acquire() Acquire a semaphore. If the internal counter is larger than zero on entry, decrement it by one and return True immediately. If it is zero on entry, block, waiting until some other coroutine has called release() to make it larger than 0, and then return True. This method is a coroutine.

locked() Returns True if semaphore can not be acquired immediately.

asyncio.run_coroutine_threadsafe(coro, loop) Submit a coroutine object to a given event loop. Return a concurrent.futures.Future to access the result. This function is meant to be called from a different thread than the one where the event loop is running. Usage: # Create a coroutine coro = asyncio.sleep(1, result=3) # Submit the coroutine to a given loop future = asyncio.run_coroutine_threadsafe(coro, loop) # Wait for the result with an optional timeout argument assert future.result(timeout

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

task_done() Indicate that a formerly enqueued task is complete. Used by queue consumers. For each get() used to fetch a task, a subsequent call to task_done() tells the queue that the processing on the task is complete. If a join() is currently blocking, it will resume when all items have been processed (meaning that a task_done() call was received for every item that had been put() into the queue). Raises ValueError if called more times than there were items placed in the queue. New in ver

class asyncio.ReadTransport Interface for read-only transports. pause_reading() Pause the receiving end of the transport. No data will be passed to the protocol’s data_received() method until resume_reading() is called. resume_reading() Resume the receiving end. The protocol’s data_received() method will be called once again if some data is available for reading.

exception asyncio.QueueEmpty Exception raised when the get_nowait() method is called on a Queue object which is empty.

exception asyncio.QueueFull Exception raised when the put_nowait() method is called on a Queue object which is full.

maxsize Number of items allowed in the queue.