Struct rustdds::dds::No_Key_DataReader

pub struct No_Key_DataReader<'a, D: DeserializeOwned, DA: DeserializerAdapter<D> = CDRDeserializerAdapter<D>> { /* fields omitted */ }

DDS DataReader for no key topics.

Implementations

impl<'a, D: 'static, DA> DataReader<'a, D, DA> where
    D: DeserializeOwned,
    DA: DeserializerAdapter<D>, 

pub fn from_keyed(
    keyed: DataReader<'a, NoKeyWrapper<D>, SAWrapper<DA>>
) -> DataReader<'a, D, DA>

pub fn read(
    &mut self,
    max_samples: usize,
    read_condition: ReadCondition
) -> Result<Vec<DataSample<&D>>>

pub fn take(
    &mut self,
    max_samples: usize,
    read_condition: ReadCondition
) -> Result<Vec<DataSample<D>>>

pub fn read_next_sample(&mut self) -> Result<Option<DataSample<&D>>>

pub fn take_next_sample(&mut self) -> Result<Option<DataSample<D>>>

pub fn iterator(&mut self) -> Result<impl Iterator<Item = &D>>

Produces an interator over the currently available NOT_READ samples. Yields only payload data, not SampleInfo metadata This is not called iter() because it takes a mutable reference to self.

pub fn conditional_iterator(
    &mut self,
    read_condition: ReadCondition
) -> Result<impl Iterator<Item = &D>>

Produces an interator over the samples filtered b ygiven condition. Yields only payload data, not SampleInfo metadata

pub fn into_iterator(&mut self) -> Result<impl Iterator<Item = D>>

Produces an interator over the currently available NOT_READ samples. Yields only payload data, not SampleInfo metadata Removes samples from DataReader. Note! If the iterator is only partially consumed, all the samples it could have provided are still removed from the Datareader.

pub fn into_conditional_iterator(
    &mut self,
    read_condition: ReadCondition
) -> Result<impl Iterator<Item = D>>

Produces an interator over the samples filtered b ygiven condition. Yields only payload data, not SampleInfo metadata Note! If the iterator is only partially consumed, all the samples it could have provided are still removed from the Datareader.

pub fn get_requested_deadline_missed_status(
    &mut self
) -> Result<Option<RequestedDeadlineMissedStatus>>

Trait Implementations

impl<'a, D, DA> Entity for DataReader<'a, D, DA> where
    D: DeserializeOwned,
    DA: DeserializerAdapter<D>, 

fn as_entity(&self) -> &EntityAttributes

fn get_guid(&self) -> GUID

fn get_entity_id(&self) -> EntityId

fn get_guid_prefix(&self) -> GuidPrefix

impl<'a, D, DA> Evented for DataReader<'a, D, DA> where
    D: DeserializeOwned,
    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, '_> HasQoSPolicy for DataReader<'_, D, DA> where
    D: DeserializeOwned,
    DA: DeserializerAdapter<D>, 

fn set_qos(&mut self, policy: &QosPolicies) -> Result<()>

fn get_qos(&self) -> &QosPolicies