Struct InterruptContext 

pub struct InterruptContext { /* private fields */ }

Interrupt context for managing human-in-the-flow interactions

The context tracks interrupt state across node executions, enabling resumption with human-provided values.

Examples

use juncture_core::interrupt::InterruptContext;
use serde_json::json;

let mut context = InterruptContext::new(
    vec![Some(json!("human_input"))],
    tokio::sync::mpsc::unbounded_channel(),
);

// Get next interrupt index (increments counter)
let index = context.next_index();

Implementations

impl InterruptContext

pub fn new( resume_values: Vec<Option<Value>>, interrupt_tx: UnboundedSender<InterruptSignal>, ) -> Self

Create a new interrupt context

Arguments

• resume_values - Values to resume interrupts with (indexed by position)
• interrupt_tx - Channel for sending interrupt signals

pub fn next_index(&self) -> usize

Get the next interrupt index (atomically increments counter)

pub fn get_resume_value(&self, index: usize) -> Option<Value>

Get resume value for a given index

Returns None if no resume value exists for this index.

pub fn current_index(&self) -> usize

Get the current index without incrementing

pub fn send_interrupt( &self, signal: InterruptSignal, ) -> Result<(), SendError<InterruptSignal>>

Send an interrupt signal

Errors

Returns an error if the interrupt channel is closed.

Trait Implementations

impl Clone for InterruptContext

fn clone(&self) -> InterruptContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InterruptContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.