Struct 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>>>

where DA: DefaultDecoder<D>,

pub fn try_take_one_with<S>( &self, decoder: S, ) -> ReadResult<Option<DeserializedCacheChange<D>>>

where S: Decode<DA::Decoded> + Clone,

pub fn qos(&self) -> &QosPolicies

pub fn guid(&self) -> GUID

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

where DA: DefaultDecoder<D>,

pub fn as_async_stream_with<'a, S>( &'a self, decoder: S, ) -> impl FusedStream<Item = ReadResult<DeserializedCacheChange<D>>> + 'a

where S: Decode<DA::Decoded> + Clone + 'a,

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, D, 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, D, DA>

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