DomainParticipantAsync

dust_dds::dds_async::domain_participant

Struct DomainParticipantAsync 

Source 
pub struct DomainParticipantAsync<R: DdsRuntime> { /* private fields */ }
Expand description

Async version of DomainParticipant.

Implementations§

Source§

impl<R: DdsRuntime> DomainParticipantAsync<R>

Source

pub async fn create_publisher( &self, qos: QosKind<PublisherQos>, a_listener: Option<impl PublisherListener<R> + Send + 'static>, mask: &[StatusKind], ) -> DdsResult<PublisherAsync<R>>

Async version of create_publisher.

Source

pub async fn delete_publisher( &self, a_publisher: &PublisherAsync<R>, ) -> DdsResult<()>

Async version of delete_publisher.

Source

pub async fn create_subscriber( &self, qos: QosKind<SubscriberQos>, a_listener: Option<impl SubscriberListener<R> + Send + 'static>, mask: &[StatusKind], ) -> DdsResult<SubscriberAsync<R>>

Async version of create_subscriber.

Source

pub async fn delete_subscriber( &self, a_subscriber: &SubscriberAsync<R>, ) -> DdsResult<()>

Async version of delete_subscriber.

Source

pub async fn create_topic<Foo>( &self, topic_name: &str, type_name: &str, qos: QosKind<TopicQos>, a_listener: Option<impl TopicListener<R> + Send + 'static>, mask: &[StatusKind], ) -> DdsResult<TopicDescriptionAsync<R>>
where Foo: TypeSupport,

Async version of create_topic.

Source

pub async fn delete_topic( &self, a_topic: &TopicDescriptionAsync<R>, ) -> DdsResult<()>

Async version of delete_topic.

Source

pub async fn create_contentfilteredtopic( &self, name: &str, related_topic: &TopicDescriptionAsync<R>, filter_expression: String, expression_parameters: Vec<String>, ) -> DdsResult<TopicDescriptionAsync<R>>

Async version of create_contentfilteredtopic.

Source

pub async fn delete_contentfilteredtopic( &self, _a_contentfilteredtopic: &TopicDescriptionAsync<R>, ) -> DdsResult<()>

Async version of delete_contentfilteredtopic.

Source

pub async fn find_topic<Foo>( &self, topic_name: &str, timeout: Duration, ) -> DdsResult<TopicDescriptionAsync<R>>
where Foo: TypeSupport,

Async version of find_topic.

Source

pub async fn lookup_topicdescription( &self, topic_name: &str, ) -> DdsResult<Option<TopicDescriptionAsync<R>>>

Async version of lookup_topicdescription.

Source

pub fn get_builtin_subscriber(&self) -> SubscriberAsync<R>

Async version of get_builtin_subscriber.

Source

pub async fn ignore_participant(&self, handle: InstanceHandle) -> DdsResult<()>

Async version of ignore_participant.

Source

pub async fn ignore_topic(&self, handle: InstanceHandle) -> DdsResult<()>

Async version of ignore_topic.

Source

pub async fn ignore_publication(&self, handle: InstanceHandle) -> DdsResult<()>

Async version of ignore_publication.

Source

pub async fn ignore_subscription(&self, handle: InstanceHandle) -> DdsResult<()>

Async version of ignore_subscription.

Source

pub fn get_domain_id(&self) -> DomainId

Async version of get_domain_id.

Source

pub async fn delete_contained_entities(&self) -> DdsResult<()>

Async version of delete_contained_entities.

Source

pub async fn assert_liveliness(&self) -> DdsResult<()>

Async version of assert_liveliness.

Source

pub async fn set_default_publisher_qos( &self, qos: QosKind<PublisherQos>, ) -> DdsResult<()>

Async version of set_default_publisher_qos.

Source

pub async fn get_default_publisher_qos(&self) -> DdsResult<PublisherQos>

Async version of get_default_publisher_qos.

Source

pub async fn set_default_subscriber_qos( &self, qos: QosKind<SubscriberQos>, ) -> DdsResult<()>

Async version of set_default_subscriber_qos.

Source

pub async fn get_default_subscriber_qos(&self) -> DdsResult<SubscriberQos>

Async version of get_default_subscriber_qos.

Source

pub async fn set_default_topic_qos( &self, qos: QosKind<TopicQos>, ) -> DdsResult<()>

Async version of set_default_topic_qos.

Source

pub async fn get_default_topic_qos(&self) -> DdsResult<TopicQos>

Async version of get_default_topic_qos.

Source

pub async fn get_discovered_participants( &self, ) -> DdsResult<Vec<InstanceHandle>>

Async version of get_discovered_participants.

Source

pub async fn get_discovered_participant_data( &self, participant_handle: InstanceHandle, ) -> DdsResult<ParticipantBuiltinTopicData>

Async version of get_discovered_participant_data.

Source

pub async fn get_discovered_topics(&self) -> DdsResult<Vec<InstanceHandle>>

Async version of get_discovered_topics.

Source

pub async fn get_discovered_topic_data( &self, topic_handle: InstanceHandle, ) -> DdsResult<TopicBuiltinTopicData>

Async version of get_discovered_topic_data.

Source

pub async fn contains_entity( &self, _a_handle: InstanceHandle, ) -> DdsResult<bool>

Async version of contains_entity.

Source

pub async fn get_current_time(&self) -> DdsResult<Time>

Async version of get_current_time.

Source§

impl<R: DdsRuntime> DomainParticipantAsync<R>

Source

pub async fn set_qos(&self, qos: QosKind<DomainParticipantQos>) -> DdsResult<()>

Async version of set_qos.

Source

pub async fn get_qos(&self) -> DdsResult<DomainParticipantQos>

Async version of get_qos.

Source

pub async fn set_listener( &self, a_listener: Option<impl DomainParticipantListener<R> + Send + 'static>, mask: &[StatusKind], ) -> DdsResult<()>

Async version of set_listener.

Source

pub async fn get_status_changes(&self) -> DdsResult<Vec<StatusKind>>

Async version of get_status_changes.

Source

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

Async version of enable.

Source

pub async fn get_instance_handle(&self) -> InstanceHandle

Async version of get_instance_handle.

Trait Implementations§

Source§

impl<R: DdsRuntime> Clone for DomainParticipantAsync<R>

Source§

fn clone(&self) -> Self

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

Auto Trait Implementations§

§

impl<R> Freeze for DomainParticipantAsync<R>
where <R as DdsRuntime>::ChannelSender<DcpsDomainParticipantMail<R>>: Freeze, <R as DdsRuntime>::SpawnerHandle: Freeze, <R as DdsRuntime>::ClockHandle: Freeze, <R as DdsRuntime>::TimerHandle: Freeze, <R as DdsRuntime>::ChannelSender<DcpsStatusConditionMail<R>>: Freeze,

§

impl<R> RefUnwindSafe for DomainParticipantAsync<R>
where <R as DdsRuntime>::ChannelSender<DcpsDomainParticipantMail<R>>: RefUnwindSafe, <R as DdsRuntime>::SpawnerHandle: RefUnwindSafe, <R as DdsRuntime>::ClockHandle: RefUnwindSafe, <R as DdsRuntime>::TimerHandle: RefUnwindSafe, <R as DdsRuntime>::ChannelSender<DcpsStatusConditionMail<R>>: RefUnwindSafe,

§

impl<R> Send for DomainParticipantAsync<R>

§

impl<R> Sync for DomainParticipantAsync<R>

§

impl<R> Unpin for DomainParticipantAsync<R>
where <R as DdsRuntime>::ChannelSender<DcpsDomainParticipantMail<R>>: Unpin, <R as DdsRuntime>::SpawnerHandle: Unpin, <R as DdsRuntime>::ClockHandle: Unpin, <R as DdsRuntime>::TimerHandle: Unpin, <R as DdsRuntime>::ChannelSender<DcpsStatusConditionMail<R>>: Unpin,

§

impl<R> UnwindSafe for DomainParticipantAsync<R>
where <R as DdsRuntime>::ChannelSender<DcpsDomainParticipantMail<R>>: UnwindSafe, <R as DdsRuntime>::SpawnerHandle: UnwindSafe, <R as DdsRuntime>::ClockHandle: UnwindSafe, <R as DdsRuntime>::TimerHandle: UnwindSafe, <R as DdsRuntime>::ChannelSender<DcpsStatusConditionMail<R>>: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more