Struct VerifySession 

pub struct VerifySession { /* private fields */ }

Drives verify-by-reread for one command over a stream of report messages.

Implementations

impl VerifySession

pub fn new(cmd: Command, seq: impl Into<String>) -> Self

Start verifying cmd, which was published with seq as its sequence_id.

pub fn observe(&mut self, message: Value) -> Option<CommandOutcome>

Feed one report message. Returns Some(outcome) once a verdict is reached; None means keep waiting (feed the next message, or call timed_out when the deadline passes).

pub fn timed_out(&self) -> CommandOutcome

The verdict when no conclusive message arrived before the timeout: distinguishes “never ACKed” from “ACKed but the effect never showed”.