Trait DomainParticipantListener 

pub trait DomainParticipantListener: Send + Sync {
    // Provided methods
    fn on_inconsistent_topic(
        &self,
        _topic: InstanceHandle,
        _status: InconsistentTopicStatus,
    ) { ... }
    fn on_offered_deadline_missed(
        &self,
        _writer: InstanceHandle,
        _status: OfferedDeadlineMissedStatus,
    ) { ... }
    fn on_offered_incompatible_qos(
        &self,
        _writer: InstanceHandle,
        _status: OfferedIncompatibleQosStatus,
    ) { ... }
    fn on_liveliness_lost(
        &self,
        _writer: InstanceHandle,
        _status: LivelinessLostStatus,
    ) { ... }
    fn on_publication_matched(
        &self,
        _writer: InstanceHandle,
        _status: PublicationMatchedStatus,
    ) { ... }
    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,
    ) { ... }
}

DomainParticipantListener — Spec §2.2.2.2.3 + §2.2.4.2.8.

Vereinigt alle Status-Callbacks aller untergeordneten Entities, weil jedes Event spec-treu nach ganz oben bubblen kann, wenn auf der engeren Entity kein Listener installiert ist.

Die Spec listet 13 Callbacks (Vereinigung aller Status-Hooks):

• 1 Topic (on_inconsistent_topic)
• 4 Writer- (on_offered_*, on_liveliness_lost, on_publication_matched)
• 7 Reader- (on_data_available, on_sample_*, on_requested_*, on_liveliness_changed, on_subscription_matched)
• 1 Subscriber- (on_data_on_readers)

Provided Methods

fn on_inconsistent_topic( &self, _topic: InstanceHandle, _status: InconsistentTopicStatus, )

Bubble-Up von TopicListener::on_inconsistent_topic.

fn on_offered_deadline_missed( &self, _writer: InstanceHandle, _status: OfferedDeadlineMissedStatus, )

Bubble-Up von PublisherListener::on_offered_deadline_missed.

fn on_offered_incompatible_qos( &self, _writer: InstanceHandle, _status: OfferedIncompatibleQosStatus, )

Bubble-Up von PublisherListener::on_offered_incompatible_qos.

fn on_liveliness_lost( &self, _writer: InstanceHandle, _status: LivelinessLostStatus, )

Bubble-Up von PublisherListener::on_liveliness_lost.

fn on_publication_matched( &self, _writer: InstanceHandle, _status: PublicationMatchedStatus, )

Bubble-Up von PublisherListener::on_publication_matched.

fn on_data_on_readers(&self, _subscriber: InstanceHandle)

Bubble-Up von SubscriberListener::on_data_on_readers.

fn on_data_available(&self, _reader: InstanceHandle)

Bubble-Up von SubscriberListener::on_data_available.

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

Bubble-Up von SubscriberListener::on_sample_lost.

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

Bubble-Up von SubscriberListener::on_sample_rejected.

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

Bubble-Up von SubscriberListener::on_requested_deadline_missed.

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

Bubble-Up von SubscriberListener::on_requested_incompatible_qos.

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

Bubble-Up von SubscriberListener::on_liveliness_changed.

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

Bubble-Up von SubscriberListener::on_subscription_matched.

Implementors