Skip to main content

drain_queue_errors

Function drain_queue_errors 

Source
pub fn drain_queue_errors(
    queue: &mut VecDeque<QueuedMessage>,
    terminal_state: ShimState,
) -> Vec<Event>
Expand description

Drain all queued messages, emitting an Error event for each one. Used when the agent enters a terminal state (Dead, ContextExhausted).