Struct Bus 

pub struct Bus { /* private fields */ }

Cross-thread event channel. Once a buffer crosses a Queue boundary, errors can no longer be propagated up the call stack with ? — they’re posted here instead so the owner of the Pipeline can observe them.

Implementations

impl Bus

pub fn new() -> (Bus, BusReceiver)

pub fn post(&self, pp_log: &PpLog, event: BusEvent)

pp_log is the posting element’s own crate::element::Element::pp_log — used (via crate::pp_log’s pp_log: macro form) instead of event’s own name so the element’s full identity, pipeline id included, reaches the log record rather than just the name carried in the event.

Trait Implementations

impl Clone for Bus

fn clone(&self) -> Bus

Returns a duplicate of the value.

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

Performs copy-assignment from source.