Struct HddsReaderListener 

#[repr(C)]
pub struct HddsReaderListener {
    pub on_data_available: HddsOnDataAvailable,
    pub on_subscription_matched: HddsOnSubscriptionMatched,
    pub on_liveliness_changed: HddsOnLivelinessChanged,
    pub on_sample_lost: HddsOnSampleLost,
    pub on_sample_rejected: HddsOnSampleRejected,
    pub on_deadline_missed: HddsOnDeadlineMissed,
    pub on_incompatible_qos: HddsOnIncompatibleQos,
    pub user_data: *mut c_void,
}

C-compatible DataReader listener.

Set callback fields to receive events. Any callback set to None (NULL) will be silently ignored. The user_data pointer is passed through to every callback invocation.

Example (C)

HddsReaderListener listener = {0};
listener.on_data_available = my_data_callback;
listener.on_subscription_matched = my_match_callback;
listener.user_data = my_context;
hdds_reader_set_listener(reader, &listener);

Fields

on_data_available: HddsOnDataAvailable

Called when new data is available to read.

on_subscription_matched: HddsOnSubscriptionMatched

Called when the reader matches/unmatches with a writer.

on_liveliness_changed: HddsOnLivelinessChanged

Called when liveliness of a matched writer changes.

on_sample_lost: HddsOnSampleLost

Called when samples are lost (gap in sequence numbers).

on_sample_rejected: HddsOnSampleRejected

Called when samples are rejected due to resource limits.

on_deadline_missed: HddsOnDeadlineMissed

Called when the requested deadline is missed.

on_incompatible_qos: HddsOnIncompatibleQos

Called when QoS is incompatible with a matched writer.

user_data: *mut c_void

User-provided context pointer, passed to all callbacks.

Trait Implementations

impl Send for HddsReaderListener

impl Sync for HddsReaderListener