Struct rustdds::dds::no_key::SimpleDataReader

pub struct SimpleDataReader<D, DA: DeserializerAdapter<D> = CDRDeserializerAdapter<D>> { /* private fields */ }

SimpleDataReaders can only do “take” semantics and does not have any deduplication or other DataSampleCache functionality.

Implementations

impl<D: 'static, DA> SimpleDataReader<D, DA>

where DA: DeserializerAdapter<D> + 'static,

pub fn set_waker(&self, w: Option<Waker>)

pub fn drain_read_notifications(&self)

pub fn try_take_one(&self) -> ReadResult<Option<DeserializedCacheChange<D>>>

pub fn qos(&self) -> &QosPolicies

pub fn guid(&self) -> GUID

pub fn as_async_stream( &self ) -> impl FusedStream<Item = ReadResult<DeserializedCacheChange<D>>> + '_

Trait Implementations

impl<D, DA> Evented for SimpleDataReader<D, DA>

where DA: DeserializerAdapter<D>,

fn register( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt ) -> Result<()>

Register self with the given Poll instance.

fn reregister( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt ) -> Result<()>

Re-register self with the given Poll instance.

fn deregister(&self, poll: &Poll) -> Result<()>

Deregister self from the given Poll instance

impl<D, DA> RTPSEntity for SimpleDataReader<D, DA>

where D: 'static, DA: DeserializerAdapter<D>,

fn guid(&self) -> GUID

fn entity_id(&self) -> EntityId

fn guid_prefix(&self) -> GuidPrefix

impl<D, DA> Source for SimpleDataReader<D, DA>

where DA: DeserializerAdapter<D>,

fn register( &mut self, registry: &Registry, token: Token, interests: Interest ) -> Result<()>

Register self with the given Registry instance.

fn reregister( &mut self, registry: &Registry, token: Token, interests: Interest ) -> Result<()>

Re-register self with the given Registry instance.

fn deregister(&mut self, registry: &Registry) -> Result<()>

Deregister self from the given Registry instance.

impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, NoKeyWrapper<D>, DAWrapper<DA>>> for SimpleDataReader<D, DA>

where D: 'static, 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, NoKeyWrapper<D>, DAWrapper<DA>>

fn try_recv_status(&self) -> Option<DataReaderStatus>