Struct ListenerBuilder 

pub struct ListenerBuilder { /* private fields */ }

Implementations

impl ListenerBuilder

pub fn new() -> Self

pub fn on_data_available(self, cb: impl Fn(i32) + Send + Sync + 'static) -> Self

pub fn on_publication_matched( self, cb: impl Fn(i32, dds_publication_matched_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_subscription_matched( self, cb: impl Fn(i32, dds_subscription_matched_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_liveliness_changed( self, cb: impl Fn(i32, dds_liveliness_changed_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_inconsistent_topic( self, cb: impl Fn(i32, dds_inconsistent_topic_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_liveliness_lost( self, cb: impl Fn(i32, dds_liveliness_lost_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_offered_deadline_missed( self, cb: impl Fn(i32, dds_offered_deadline_missed_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_offered_incompatible_qos( self, cb: impl Fn(i32, dds_offered_incompatible_qos_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_data_on_readers( self, cb: impl Fn(i32) + Send + Sync + 'static, ) -> Self

pub fn on_sample_lost( self, cb: impl Fn(i32, dds_sample_lost_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_sample_rejected( self, cb: impl Fn(i32, dds_sample_rejected_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_requested_deadline_missed( self, cb: impl Fn(i32, dds_requested_deadline_missed_status_t) + Send + Sync + 'static, ) -> Self

pub fn on_requested_incompatible_qos( self, cb: impl Fn(i32, dds_requested_incompatible_qos_status_t) + Send + Sync + 'static, ) -> Self

pub fn build(self) -> DdsResult<Listener>

Trait Implementations

impl Default for ListenerBuilder

fn default() -> Self

Returns the “default value” for a type.