Struct Subscriber 

pub struct Subscriber { /* private fields */ }

Subscriber — entity group for DataReaders.

Implementations

impl Subscriber

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

Spec §2.2.2.2.1.10 — true if handle is a DataReader created via this Subscriber.

pub fn begin_access(&self)

Spec §2.2.2.5.2.8 begin_access — marks the start of a coherent read set. Nesting is allowed; each call increments an internal counter, each end_access decrements it.

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

Spec §2.2.2.5.2.9 end_access — counterpart to begin_access.

Errors

DdsError::PreconditionNotMet if end_access is called without a preceding begin_access.

pub fn is_access_open(&self) -> bool

true if a group access is currently open.

pub fn set_listener( &self, listener: Option<ArcSubscriberListener>, mask: StatusMask, )

Sets the SubscriberListener + StatusMask. None clears the slot. Spec §2.2.2.5.6.x set_listener.

pub fn get_listener(&self) -> Option<ArcSubscriberListener>

Current listener clone.

pub fn create_datareader<T: DdsType + Send + 'static>( &self, topic: &Topic<T>, qos: DataReaderQos, ) -> Result<DataReader<T>>

Creates a typed DataReader<T>.

Errors

BadParameter on a type-name mismatch.

Trait Implementations

impl Debug for Subscriber

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

Formats the value using the given formatter.

impl Entity for Subscriber

Available on crate feature std only.

type Qos = SubscriberQos

QoS type for this entity (e.g. DomainParticipantQos, DataWriterQos, …).

fn get_qos(&self) -> Self::Qos

Returns the current QoS (clone). Spec §2.2.2.1.2 get_qos.

fn set_qos(&self, qos: Self::Qos) -> Result<()>

Changes the QoS. Before enable: everything allowed. After enable: only fields with “Changeable=YES” — otherwise an ImmutablePolicy error. Spec §2.2.2.1.2 set_qos.

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

Enables the entity (idempotent). Spec §2.2.2.1.4 enable.

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

Internal accessor — each impl returns its Arc<EntityState>.

fn is_enabled(&self) -> bool

True if the entity is already enabled.

fn get_status_condition(&self) -> StatusCondition

StatusCondition of this entity. Spec §2.2.2.1.6 get_status_condition.

fn get_status_changes(&self) -> StatusMask

Bitmask of the status kinds changed since the last read. Spec §2.2.2.1.5 get_status_changes.

fn get_instance_handle(&self) -> InstanceHandle

Local 64-bit identifier. Spec §2.2.2.1.7 get_instance_handle.