RTI Routing Service Version 7.2.0
|
Representation of an Input whose data representation is DataRep
, whose info representation is InfoRep
.
More...
#include <Input.hpp>
Public Member Functions | |
const rti::routing::StreamInfo & | stream_info () const |
Returns the StreamInfo associated with this object. More... | |
const std::string & | name () const |
Returns the name of this output. More... | |
LoanedSamples< Data, Info > | take () |
Returns all the available samples in this object. More... | |
LoanedSamples< Data, Info > | read () |
Same as take() but this calls rti::routing::adapter::StreamReader::read instead. More... | |
Selector | select () |
Gets a Selector to perform complex data selections, such as per-instance selection, content and status filtering. More... | |
bool | active () |
Indicates whether this input has received new data since the last time any variant of the read operations was called. More... | |
Data | create_data () |
Creates a new data sample from this input. More... | |
dds::sub::DataReader< Data > | dds_data_reader () |
Returns the underlying DDS DataReader that is part of this StreamReader implementation, assuming this input holds a DDS StreamReader. More... | |
Friends | |
class | rti::routing::processor::Selector< Data, Info > |
class | rti::routing::processor::Route |
Representation of an Input whose data representation is DataRep
, whose info representation is InfoRep
.
const rti::routing::StreamInfo & rti::routing::processor::TypedInput< Data, Info >::stream_info |
Returns the StreamInfo associated with this object.
The associated StreamInfo represents an equivalent object to the one used to create the underlying rti::routing::adapter::StreamReader.
const std::string & rti::routing::processor::TypedInput< Data, Info >::name |
Returns the name of this output.
The name is given by the name of the corresponding XML configuration tag.
LoanedSamples< Data, Info > rti::routing::processor::TypedInput< Data, Info >::take |
Returns all the available samples in this object.
This operation will call rti::routing::adapter::StreamReader::take on the underlying rti::routing::adapter::StreamReader.
The returned samples are interpreted to contain data represented as Data
and info represented as Info
.
LoanedSamples< Data, Info > rti::routing::processor::TypedInput< Data, Info >::read |
Same as take() but this calls rti::routing::adapter::StreamReader::read instead.
rti::routing::processor::Selector< Data, Info > rti::routing::processor::TypedInput< Data, Info >::select |
Gets a Selector to perform complex data selections, such as per-instance selection, content and status filtering.
The selector can be used as follows:
This shows how samples can be taken by selecting a specific instance, then filtering by state and content.
Note that when the application wants to access all available samples, it can simply call read() or take().
bool rti::routing::processor::TypedInput< Data, Info >::active |
Indicates whether this input has received new data since the last time any variant of the read operations was called.
Data rti::routing::processor::TypedInput< Data, Info >::create_data |
Creates a new data sample from this input.
The data constructor called in this operation depends on the data representation kind of the TypeInfo associated with this input. If the type representation is a dynamic type, then it will assume the following constructor:
and will use the type code object downcasted from the value returned by TypeInfo::type_representation.
Otherwise:
|
inline |
Returns the underlying DDS DataReader that is part of this StreamReader implementation, assuming this input holds a DDS StreamReader.
This operation will throw an exception if this input does not hold a DDS StreamReader.
std::exception |