Struct PendingWrites 

pub struct PendingWrites<U: StateUpdate> { /* private fields */ }

Tracks node write outcomes within a single superstep.

Example

let mut writes = PendingWrites::new();
writes.record_success("chat", update);
writes.record_failure("tools", &PeError::ToolExecution { .. });

if writes.has_failures() {
    // Only re-run failed nodes on resume
}

Implementations

impl<U: StateUpdate> PendingWrites<U>

pub fn new() -> Self

Create an empty write tracker.

pub fn record_success(&mut self, node_name: &str, update: U)

Record a successful node execution with its update.

pub fn record_failure(&mut self, node_name: &str, error: &PeError)

Record a failed node execution.

pub fn has_failures(&self) -> bool

Returns true if any node failed in this superstep.

pub fn successes(&self) -> &[(String, U)]

View successful node writes.

pub fn failures(&self) -> &[(String, String)]

View failed nodes and their error messages.

pub fn drain_successes(&mut self) -> Vec<(String, U)>

Drain all successful writes, leaving the tracker empty.

Trait Implementations

impl<U: Clone + StateUpdate> Clone for PendingWrites<U>

fn clone(&self) -> PendingWrites<U>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<U: Debug + StateUpdate> Debug for PendingWrites<U>

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

Formats the value using the given formatter.

impl<U: StateUpdate> Default for PendingWrites<U>

fn default() -> Self

Returns the “default value” for a type.