Struct Subscriber 

pub struct Subscriber { /* private fields */ }

Implementations

impl Subscriber

pub fn new(participant: dds_entity_t) -> DdsResult<Self>

pub fn with_qos(participant: dds_entity_t, qos: Option<&Qos>) -> DdsResult<Self>

pub fn with_listener( participant: dds_entity_t, listener: &Listener, ) -> DdsResult<Self>

pub fn with_qos_and_listener( participant: dds_entity_t, qos: Option<&Qos>, listener: Option<&Listener>, ) -> DdsResult<Self>

pub fn create_reader<T: DdsType>( &self, topic: &Topic<T>, ) -> DdsResult<DataReader<T>>

pub fn create_reader_with_qos<T: DdsType>( &self, topic: &Topic<T>, qos: &Qos, ) -> DdsResult<DataReader<T>>

pub fn notify_readers(&self) -> DdsResult<()>

pub fn begin_coherent(&self) -> DdsResult<()>

Begin coherent access on this subscriber.

Coherent access groups a set of data changes so that they are made available to readers as an atomic set.

pub fn end_coherent(&self) -> DdsResult<()>

End coherent access on this subscriber.

Must be paired with a prior begin_coherent call.

Trait Implementations

impl DdsEntity for Subscriber

fn entity(&self) -> dds_entity_t

fn get_parent(&self) -> DdsResult<dds_entity_t>

fn get_participant(&self) -> DdsResult<dds_entity_t>

fn get_publisher(&self) -> DdsResult<dds_entity_t>

fn get_subscriber(&self) -> DdsResult<dds_entity_t>

fn get_datareader(&self) -> DdsResult<dds_entity_t>

fn get_topic(&self) -> DdsResult<dds_entity_t>

fn get_children(&self) -> DdsResult<Vec<dds_entity_t>>

fn get_name(&self) -> DdsResult<String>

fn get_type_name(&self) -> DdsResult<String>

fn get_domain_id(&self) -> DdsResult<u32>

fn get_instance_handle(&self) -> DdsResult<dds_instance_handle_t>

fn get_guid(&self) -> DdsResult<dds_guid_t>

fn guid(&self) -> DdsResult<dds_guid_t>

Convenience alias for Self::get_guid.

fn status(&self) -> DdsResult<EntityStatus>

Read a consolidated status snapshot for this entity.

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

fn get_status_mask(&self) -> DdsResult<u32>

fn set_status_mask(&self, mask: u32) -> DdsResult<()>

fn get_status_changes(&self) -> DdsResult<u32>

fn read_status(&self, mask: u32) -> DdsResult<u32>

fn take_status(&self, mask: u32) -> DdsResult<u32>

fn status_changes(&self) -> DdsResult<u32>

Get the set of triggered status bits that have changed since the last time they were read.

fn triggered(&self) -> DdsResult<bool>

fn is_shared_memory_available(&self) -> bool

fn create_statistics(&self) -> DdsResult<Statistics>

fn get_qos(&self) -> DdsResult<Qos>

fn get_sertype(&self) -> DdsResult<SertypeHandle>

fn get_type_info(&self) -> DdsResult<TypeInfo>

fn get_type_object( &self, type_id: *const dds_typeid_t, timeout: dds_duration_t, ) -> DdsResult<TypeObject>

fn get_minimal_type_object( &self, timeout: dds_duration_t, ) -> DdsResult<Option<TypeObject>>

fn get_complete_type_object( &self, timeout: dds_duration_t, ) -> DdsResult<Option<TypeObject>>

fn matches_entity_type_info<E: DdsEntity>(&self, other: &E) -> DdsResult<bool>

impl Drop for Subscriber

fn drop(&mut self)

Executes the destructor for this type.