Struct RecordingObserver 

pub struct RecordingObserver { /* private fields */ }

A recording observer that stores all events.

Useful for testing and debugging protocol execution.

Implementations

impl RecordingObserver

pub fn new() -> Self

Create a new recording observer.

pub fn events(&self) -> &[ProtocolEvent]

Get all recorded events.

pub fn take_events(&mut self) -> Vec<ProtocolEvent>

Take all recorded events, clearing the observer.

pub fn clear(&mut self)

Clear all recorded events.

pub fn len(&self) -> usize

Get the number of recorded events.

pub fn is_empty(&self) -> bool

Check if no events have been recorded.

pub fn sends(&self) -> impl Iterator<Item = &ProtocolEvent>

Get send events only.

pub fn recvs(&self) -> impl Iterator<Item = &ProtocolEvent>

Get recv events only.

pub fn errors(&self) -> impl Iterator<Item = &ProtocolEvent>

Get error events only.

Trait Implementations

impl Debug for RecordingObserver

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

Formats the value using the given formatter.

impl Default for RecordingObserver

fn default() -> RecordingObserver

Returns the “default value” for a type.

impl ProtocolObserver for RecordingObserver

fn on_phase_start(&mut self, protocol: &str, role: &str, phase: &str)

Called when a protocol phase starts.

fn on_phase_end(&mut self, protocol: &str, role: &str, phase: &str)

Called when a protocol phase ends.

fn on_send(&mut self, from: &str, to: &str, msg_type: &str, size: usize)

Called when a message is sent.

fn on_recv(&mut self, from: &str, to: &str, msg_type: &str, size: usize)

Called when a message is received.

fn on_choice(&mut self, decider: &str, branch: &str)

Called when a choice is made (internal choice).

fn on_offer(&mut self, from: &str, branch: &str)

Called when a choice is received (external choice).

fn on_error(&mut self, protocol: &str, role: &str, error: &ChoreographyError)

Called when an error occurs.

fn on_complete(&mut self, protocol: &str, role: &str)

Called when the protocol completes successfully.