Class dds::sub::DataReader

Class dds::sub::DataReader

template <typename T>

ClassList > dds > sub > DataReader

Public Functions

Type Name
DataReader (Subscriber & subscriber, dds::topic::Topic< T > & topic, const astutedds::dcps::DataReaderQos & qos={})
DataReader (Subscriber & subscriber, dds::topic::ContentFilteredTopic< T > & cft, const astutedds::dcps::DataReaderQos & qos={})
DataReader (const DataReader &) = delete
DataReader & operator= (const DataReader &) = delete
astutedds::dcps::DataReader * raw () const
std::shared_ptr< dds::core::cond::ReadCondition > read_condition ()
ReadCondition for WaitSet — triggers when unread data is available.
astutedds::dcps::ReturnCode_t read_next (T & sample, astutedds::dcps::SampleInfo & info)
Non-destructive read of the next sample (keeps sample in cache).
std::shared_ptr< dds::core::cond::StatusCondition > status_condition ()
StatusCondition for WaitSet — triggers when unread data is available.
astutedds::dcps::ReturnCode_t take_next (T & sample, astutedds::dcps::SampleInfo & info)
Destructive read of the next sample (removes from cache).
~DataReader ()

Public Functions Documentation

function DataReader [1/3]

inline dds::sub::DataReader::DataReader (
    Subscriber & subscriber,
    dds::topic::Topic < T > & topic,
    const astutedds::dcps::DataReaderQos & qos={}
)

function DataReader [2/3]

inline dds::sub::DataReader::DataReader (
    Subscriber & subscriber,
    dds::topic::ContentFilteredTopic < T > & cft,
    const astutedds::dcps::DataReaderQos & qos={}
)

function DataReader [3/3]

dds::sub::DataReader::DataReader (
    const DataReader &
) = delete

function operator=

DataReader & dds::sub::DataReader::operator= (
    const DataReader &
) = delete

function raw

inline astutedds::dcps::DataReader * dds::sub::DataReader::raw () const

function read_condition

ReadCondition for WaitSet — triggers when unread data is available. 

inline std::shared_ptr< dds::core::cond::ReadCondition > dds::sub::DataReader::read_condition ()

function read_next

Non-destructive read of the next sample (keeps sample in cache). 

inline astutedds::dcps::ReturnCode_t dds::sub::DataReader::read_next (
    T & sample,
    astutedds::dcps::SampleInfo & info
)

function status_condition

StatusCondition for WaitSet — triggers when unread data is available. 

inline std::shared_ptr< dds::core::cond::StatusCondition > dds::sub::DataReader::status_condition ()

function take_next

Destructive read of the next sample (removes from cache). 

inline astutedds::dcps::ReturnCode_t dds::sub::DataReader::take_next (
    T & sample,
    astutedds::dcps::SampleInfo & info
)

function ~DataReader

inline dds::sub::DataReader::~DataReader ()

The documentation for this class was generated from the following file include/astutedds/dcps/CorePolicy.hpp