Struct MultiObserver 

pub struct MultiObserver<'a> { /* private fields */ }

A multiplexing observer that forwards events to multiple observers.

Implementations

impl<'a> MultiObserver<'a>

pub fn new(observers: Vec<&'a mut dyn ProtocolObserver>) -> Self

Create a new multi-observer.

Trait Implementations

impl ProtocolObserver for MultiObserver<'_>

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.