Struct Publisher 

pub struct Publisher { /* private fields */ }

Publisher — Entity-Gruppe fuer DataWriter.

In DDS 1.4 hat der Publisher eigene QoS (Partition, Group-Data, Presentation). v1.2 implementiert nur die API-Shape ohne Partition-Matching.

Implementations

impl Publisher

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

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

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

setzt den PublisherListener + StatusMask. None loescht den Slot. Spec §2.2.2.4.3.x.

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

aktueller Listener-Klon, sofern vorhanden.

pub fn suspend_publications(&self)

Spec §2.2.2.4.1.10 suspend_publications — Hint an die Service, dass nachfolgende write()-Aufrufe gepuffert werden duerfen (z.B. fuer Coalescing). Hat keine Pflicht-Semantik fuer den Caller; der Flag ist via is_suspended() lesbar fuer die Writer-Implementation.

Idempotent: ein zweites suspend_publications() ohne resume_publications() dazwischen ist erlaubt.

pub fn resume_publications(&self)

Spec §2.2.2.4.1.11 resume_publications — Gegenstueck zu suspend_publications. Bei aktivem Suspend-Flag ist das Verhalten “Service can stop coalescing”; bei inaktivem Flag ist das ein No-Op.

pub fn is_suspended(&self) -> bool

true wenn suspend_publications() aktiv ist und resume_publications() noch nicht gerufen wurde. Wird vom Writer-Send-Pfad als Coalescing-Hint gelesen.

pub fn copy_from_topic_qos( dw_qos: &mut DataWriterQos, topic_qos: &TopicQos, ) -> Result<(), DdsError>

Spec §2.2.2.4.1.13 copy_from_topic_qos — kopiert die zwischen Topic- und DataWriter-Qos teilbaren Policies aus topic_qos nach dw_qos. Spec-Liste der gemeinsamen Policies (DCPS 1.4 §2.2.2.4.1.13): DURABILITY, DEADLINE, LATENCY_BUDGET, LIVELINESS, RELIABILITY, DESTINATION_ORDER, HISTORY, RESOURCE_LIMITS, TRANSPORT_PRIORITY, LIFESPAN, OWNERSHIP.

Errors

DdsError::BadParameter wenn das Resultat eine inkonsistente QoS-Kombination ergibt — wird vom QoS-Compatibility-Check des Caller-DataWriter validiert (analog set_qos).

pub fn create_datawriter<T>( &self, topic: &Topic<T>, qos: DataWriterQos, ) -> Result<DataWriter<T>, DdsError>

where T: DdsType + Send + 'static,

Erzeugt einen typed DataWriter<T>. Spec §2.2.2.4.1.5 create_datawriter.

Errors

• BadParameter wenn topic.type_name() != T::TYPE_NAME (sollte statisch garantiert sein, aber defensiv pruefen).

Trait Implementations

impl Debug for Publisher

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

Formats the value using the given formatter.

impl Entity for Publisher

Available on crate feature std only.

type Qos = PublisherQos

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

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

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

fn set_qos(&self, qos: <Publisher 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.