Struct Topic 

pub struct Topic<T> { /* private fields */ }

Implementations

impl<T: DdsType> Topic<T>

pub fn new(participant: dds_entity_t, name: &str) -> DdsResult<Self>

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

Trait Implementations

impl<T> DdsEntity for Topic<T>

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<T> Drop for Topic<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: DdsType + 'static> TopicFilterExt<T> for Topic<T>

fn set_filter<F: Fn(&T) -> bool + Send + Sync + 'static>( &self, filter: F, ) -> DdsResult<()>

Set a writer-side filter that drops samples before they go on the wire.

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

Remove any previously set writer-side filter.

impl<T: DdsType + 'static> TopicParameterizedFilterExt<T> for Topic<T>

fn with_params<F>( &self, filter: F, ) -> DdsResult<(ContentFilteredTopic<T>, FilterParams)>

where F: Fn(&T, &FilterParams) -> bool + Send + Sync + 'static,

Create a content-filtered topic with a parameterized filter.