aea.helpers.async_friendly_queue
This module contains the implementation of AsyncFriendlyQueue.
AsyncFriendlyQueue Objects
class AsyncFriendlyQueue(queue.Queue)
queue.Queue with async_get method.
__init__
| __init__(*args, **kwargs)
Init queue.
put
| put(item: Any, *args, **kwargs) -> None
Put an item into the queue.
Arguments:
item: item to put in the queue :param args, kwargs: similar to queue.Queue.put
get
| get(*args, **kwargs) -> Any
Get an item into the queue.
:param args, kwargs: similar to queue.Queue.get
async_wait
| async async_wait() -> None
Wait an item appears in the queue.
Returns:
None
async_get
| async async_get() -> Any
Wait and get an item from the queue.
Returns:
item from queue