ewoksfluo.xrffit.handlers.queue.consume_handler_queue#

ewoksfluo.xrffit.handlers.queue.consume_handler_queue(output_handlers, queue, all_sendids, raise_on_error)[source]#
Parameters:

  • output_handlers (Dict[int, NexusOutputHandler])

  • queue (Queue)

  • all_sendids (Set[int])

  • raise_on_error (Callable[[], None])