(self, queue: InternalQueue, error_queue: ErrorQueueType)
Initialise the invoker

        The callable specified by `on_exception` will be called with a single positional argument,
        which is the exception which occurred. This should take care of shutting down the invoker,
        as well as any other cleanup which needs to happen.
Initialise the invoker
Initialise the invoker
def __init__(self, queue: InternalQueue, error_queue: ErrorQueueType):
        """Initialise the invoker

        The callable specified by `on_exception` will be called with a single positional argument,
        which is the exception which occurred. This should take care of shutting down the invoker,
        as well as any other cleanup which needs to happen.
        """
        self._queue_monitor_task: Optional[asyncio.Task] = None
        self._monitor_ready = asyncio.Event()
        self.queue = queue
        self.error_queue = error_queue
def __init__ ( self , queue : InternalQueue , error_queue : ErrorQueueType ) : self . _queue_monitor_task : Optional [ asyncio . Task ] = None self . _monitor_ready = asyncio . Event ( ) self . queue = queue self . error_queue = error_queue