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: Any, **kwargs: Any) -> None
Init queue.
put
| put(item: Any, *args: Any, **kwargs: Any) -> 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: Any, **kwargs: Any) -> 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