Struct rustdds::dds::with_key::SimpleDataReader
source · pub struct SimpleDataReader<D: Keyed, DA: DeserializerAdapter<D> = CDRDeserializerAdapter<D>> { /* private fields */ }
Expand description
SimpleDataReaders can only do “take” semantics and does not have any deduplication or other DataSampleCache functionality.
Implementations§
source§impl<D, DA> SimpleDataReader<D, DA>where
D: Keyed + 'static,
DA: DeserializerAdapter<D>,
impl<D, DA> SimpleDataReader<D, DA>where
D: Keyed + 'static,
DA: DeserializerAdapter<D>,
sourcepub fn try_take_one(&self) -> ReadResult<Option<DeserializedCacheChange<D>>>
pub fn try_take_one(&self) -> ReadResult<Option<DeserializedCacheChange<D>>>
Note: Always remember to call .drain_read_notifications() just before calling this one. Otherwise, new notifications may not appear.
pub fn qos(&self) -> &QosPolicies
pub fn guid(&self) -> GUID
pub fn topic(&self) -> &Topic
pub fn as_async_stream(&self) -> SimpleDataReaderStream<'_, D, DA>
Trait Implementations§
source§impl<D, DA> Drop for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
impl<D, DA> Drop for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
source§impl<D, DA> Evented for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
impl<D, DA> Evented for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
source§impl<D, DA> RTPSEntity for SimpleDataReader<D, DA>
impl<D, DA> RTPSEntity for SimpleDataReader<D, DA>
source§impl<D, DA> Source for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
impl<D, DA> Source for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
source§impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, D, DA>> for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, D, DA>> for SimpleDataReader<D, DA>where
D: Keyed,
DA: DeserializerAdapter<D>,
fn as_status_evented(&mut self) -> &dyn Evented
fn as_status_source(&mut self) -> &mut dyn Source
fn as_async_status_stream(&'a self) -> SimpleDataReaderEventStream<'a, D, DA>
fn try_recv_status(&self) -> Option<DataReaderStatus>
Auto Trait Implementations§
impl<D, DA = CDRDeserializerAdapter<D>> !Freeze for SimpleDataReader<D, DA>
impl<D, DA = CDRDeserializerAdapter<D>> !RefUnwindSafe for SimpleDataReader<D, DA>
impl<D, DA> Send for SimpleDataReader<D, DA>
impl<D, DA> Sync for SimpleDataReader<D, DA>
impl<D, DA> Unpin for SimpleDataReader<D, DA>where
DA: DeserializerAdapter<D> + Unpin,
impl<D, DA = CDRDeserializerAdapter<D>> !UnwindSafe for SimpleDataReader<D, DA>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more