Struct AsyncDataWriter 

pub struct AsyncDataWriter<T: DdsType + Send + Sync + 'static> { /* private fields */ }

Async-Wrapper um DataWriter<T>.

Hot-Path: write() ist eine Future-Form ueber dem sync-Pfad mit einer yield-basierten Retry-Schleife fuer OutOfResources-Backpressure (Spec §5.1 zerodds-async-1.0). Statt eines Thread-Block-Condvar::wait_timeout fallen Caller-Tasks per yield_for aus dem Executor und bleiben cancelable. Andere DCPS-Methoden delegieren synchron — sie sind ohnehin nicht blockierend.

Implementations

impl<T: DdsType + Send + Sync + 'static> AsyncDataWriter<T>

pub async fn write(&self, sample: &T) -> Result<()>

where T: Clone,

Schreibt einen Sample. Spec §2.1.1.

Errors

Wie DataWriter::write — OutOfResources nach max_blocking_time-Timeout, sonst alle anderen Errors transparent durchgereicht.

Spec §5.1 zerodds-async-1.0: bei OutOfResources suspendiert der Future via yield_for und retried, bis entweder ein Drain passiert oder die reliability.max_blocking_time abgelaufen ist. Im Sync-Pfad wuerde hier ein Condvar::wait_timeout blockieren — async-Pfad nutzt yield-retry-Loop ohne Thread-Block.

pub async fn register_instance(&self, sample: &T) -> Result<InstanceHandle>

Spec §2.1.2 register_instance.

Errors

Wie sync.

pub async fn dispose(&self, sample: &T, handle: InstanceHandle) -> Result<()>

Spec §2.1.3 dispose. Loest Wire-Lifecycle DISPOSED.

Errors

Wie sync.

pub async fn unregister_instance( &self, sample: &T, handle: InstanceHandle, ) -> Result<()>

Spec §2.1.4 unregister_instance.

Errors

Wie sync.

pub async fn wait_for_matched_subscription( &self, min_count: usize, timeout: Duration, ) -> Result<()>

Spec §2.1.5 wait_for_matched_subscription. Async-Polling- Schleife mit 10 ms Tick.

Errors

Wie sync — Timeout wenn min_count nicht in timeout erreicht.

pub fn matched_subscription_count(&self) -> usize

Spec §2.1.6 matched_subscription_count (synchron).

pub fn as_sync(&self) -> &DataWriter<T>

Liefert die zugrundeliegende sync-Variante.

pub fn qos(&self) -> DataWriterQos

Liefert die DataWriterQos.

Trait Implementations

impl<T: DdsType + Send + Sync + 'static> Clone for AsyncDataWriter<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.