Trait SubscriberListener 

pub trait SubscriberListener: Send + Sync {
    // Provided methods
    fn on_data_on_readers(&self, _subscriber: InstanceHandle) { ... }
    fn on_data_available(&self, _reader: InstanceHandle) { ... }
    fn on_sample_lost(&self, _reader: InstanceHandle, _status: SampleLostStatus) { ... }
    fn on_sample_rejected(
        &self,
        _reader: InstanceHandle,
        _status: SampleRejectedStatus,
    ) { ... }
    fn on_requested_deadline_missed(
        &self,
        _reader: InstanceHandle,
        _status: RequestedDeadlineMissedStatus,
    ) { ... }
    fn on_requested_incompatible_qos(
        &self,
        _reader: InstanceHandle,
        _status: RequestedIncompatibleQosStatus,
    ) { ... }
    fn on_liveliness_changed(
        &self,
        _reader: InstanceHandle,
        _status: LivelinessChangedStatus,
    ) { ... }
    fn on_subscription_matched(
        &self,
        _reader: InstanceHandle,
        _status: SubscriptionMatchedStatus,
    ) { ... }
}

SubscriberListener — Spec §2.2.2.5.6 + §2.2.4.2.7.

Erbt alle 7 Reader-Callbacks + 1 zusätzlichen on_data_on_readers.

Provided Methods

fn on_data_on_readers(&self, _subscriber: InstanceHandle)

Spec §2.2.4.2.7.1 — irgendein Reader des Subscribers hat neue Daten (Subscriber-Level-Notification).

fn on_data_available(&self, _reader: InstanceHandle)

Bubble-Up von DataReaderListener::on_data_available.

fn on_sample_lost(&self, _reader: InstanceHandle, _status: SampleLostStatus)

Bubble-Up von DataReaderListener::on_sample_lost.

fn on_sample_rejected( &self, _reader: InstanceHandle, _status: SampleRejectedStatus, )

Bubble-Up von DataReaderListener::on_sample_rejected.

fn on_requested_deadline_missed( &self, _reader: InstanceHandle, _status: RequestedDeadlineMissedStatus, )

Bubble-Up von DataReaderListener::on_requested_deadline_missed.

fn on_requested_incompatible_qos( &self, _reader: InstanceHandle, _status: RequestedIncompatibleQosStatus, )

Bubble-Up von DataReaderListener::on_requested_incompatible_qos.

fn on_liveliness_changed( &self, _reader: InstanceHandle, _status: LivelinessChangedStatus, )

Bubble-Up von DataReaderListener::on_liveliness_changed.

fn on_subscription_matched( &self, _reader: InstanceHandle, _status: SubscriptionMatchedStatus, )

Bubble-Up von DataReaderListener::on_subscription_matched.

Implementors