Struct Subscriber 

pub struct Subscriber { /* private fields */ }

Subscriber — Entity-Gruppe fuer DataReader.

Implementations

impl Subscriber

pub fn contains_reader(&self, handle: InstanceHandle) -> bool

Spec §2.2.2.2.1.10 — true wenn handle ein DataReader ist, der ueber diesen Subscriber erzeugt wurde.

pub fn begin_access(&self)

Spec §2.2.2.5.2.8 begin_access — markiert den Beginn eines kohaerenten Read-Sets. Verschachtelung ist erlaubt; jeder Aufruf erhoeht einen internen Counter, jedes end_access erniedrigt ihn.

pub fn end_access(&self) -> Result<(), DdsError>

Spec §2.2.2.5.2.9 end_access — Gegenstueck zu begin_access.

Errors

DdsError::PreconditionNotMet wenn end_access ohne vorhergehendes begin_access gerufen wird.

pub fn is_access_open(&self) -> bool

true wenn aktuell ein Group-Access offen ist.

pub fn set_listener( &self, listener: Option<Arc<dyn SubscriberListener>>, mask: u32, )

setzt den SubscriberListener + StatusMask. None loescht den Slot. Spec §2.2.2.5.6.x set_listener.

pub fn get_listener(&self) -> Option<Arc<dyn SubscriberListener>>

aktueller Listener-Klon.

pub fn create_datareader<T>( &self, topic: &Topic<T>, qos: DataReaderQos, ) -> Result<DataReader<T>, DdsError>

where T: DdsType + Send + 'static,

Erzeugt einen typed DataReader<T>.

Errors

BadParameter bei Type-Name-Mismatch.

Trait Implementations

impl Debug for Subscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Entity for Subscriber

Available on crate feature std only.

type Qos = SubscriberQos

QoS-Typ fuer diese Entity (z.B. DomainParticipantQos, DataWriterQos, …).

fn get_qos(&self) -> <Subscriber as Entity>::Qos

Liefert die aktuelle QoS (clone). Spec §2.2.2.1.2 get_qos.

fn set_qos(&self, qos: <Subscriber as Entity>::Qos) -> Result<(), DdsError>

Aendert QoS. Pre-enable: alles erlaubt. Post-enable: nur Felder mit “Changeable=YES” — sonst ImmutablePolicy-Error. Spec §2.2.2.1.2 set_qos.

fn enable(&self) -> Result<(), DdsError>

Enabled die Entity (idempotent). Spec §2.2.2.1.4 enable.

fn entity_state(&self) -> Arc<EntityState>

Interner Accessor — jede Impl liefert ihren Arc<EntityState>.

fn is_enabled(&self) -> bool

True wenn die Entity bereits enabled ist.

fn get_status_condition(&self) -> StatusCondition

StatusCondition dieser Entity. Spec §2.2.2.1.6 get_status_condition.

fn get_status_changes(&self) -> u32

Bitmask der Status-Kinds, die seit letztem Read geaendert haben. Spec §2.2.2.1.5 get_status_changes.

fn get_instance_handle(&self) -> InstanceHandle

Lokaler 64-Bit-Identifier. Spec §2.2.2.1.7 get_instance_handle.