fetcher/each¶
-
module
fetcher.each¶ 1 message from each fetcher.
Fetches 1 message from each inbox.
-
class
fetcher.each.EachFetcher(inboxes)¶ Arguments: - inboxes (Iterable.<Inbox>) – Inboxes to fetch from.
-
fetcher.each.EachFetcher.fetch(timeout=null)¶ Arguments: - timeout (number) – Maximum time to wait in milliseconds. null to wait forever.
Returns: Array.<*> – The fetched messages in same order as inboxes.
-
class