AbstractDataReader(OsplServiceEnvironment environment, SubscriberImpl parent, TopicDescriptionExt< TYPE > topicDescription) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
closeContainedEntities() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
conditions | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | protected |
createIterator(Object sampleSeqHolder, Field sampleSeqHolderValueField, SampleInfoSeqHolder info) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
AbstractDataReader< PROTOBUF_TYPE >.createIterator(Object sampleSeqHolder, Field sampleSeqHolderValueField, DDS.SampleInfoSeqHolder info) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
createQueryCondition(String queryExpression, List< String > queryParameters) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
createQueryCondition(DataState states, String queryExpression, List< String > queryParameters) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
createQueryCondition(String queryExpression, String... queryParameters) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
createQueryCondition(DataState states, String queryExpression, String... queryParameters) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
createReadCondition(DataState states) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
DataReaderProtobuf(OsplServiceEnvironment environment, SubscriberImpl parent, TopicDescriptionExt< PROTOBUF_TYPE > topicDescription, DataReaderQos qos, DataReaderListener< PROTOBUF_TYPE > listener, Collection< Class<? extends Status >> statuses) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
deregisterIterator(AbstractIterator< TYPE > iterator) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
destroy() | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | protected |
destroyReadCondition(ReadConditionImpl< TYPE > condition) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getKeyValue(PROTOBUF_TYPE keyHolder, InstanceHandle handle) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
getKeyValue(InstanceHandle handle) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
getLivelinessChangedStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getMatchedPublicationData(InstanceHandle publicationHandle) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getMatchedPublications() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getParent() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getPreAllocator(List< Sample< PROTOBUF_TYPE >> samples, Class<?> sampleSeqHolderClz, Field sampleSeqHolderValueField) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
AbstractDataReader< PROTOBUF_TYPE >.getPreAllocator(List< Sample< TYPE >> samples, Class<?> sampleSeqHolderClz, Field sampleSeqHolderValueField) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getProperty(String key) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getQos() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getReflectionReader() | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | protected |
getRequestedDeadlineMissedStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getRequestedIncompatibleQosStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getSampleLostStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getSampleRejectedStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getStatusCondition() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getSubscriptionMatchedStatus() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
getTopicDescription() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
iterators | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | protected |
lookupInstance(PROTOBUF_TYPE keyHolder) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
read() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
read(org.omg.dds.sub.DataReader.Selector< TYPE > query) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
read(int maxSamples) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
read(List< Sample< TYPE >> samples) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
read(List< Sample< TYPE >> samples, org.omg.dds.sub.DataReader.Selector< TYPE > selector) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
readNextSample(Sample< PROTOBUF_TYPE > sample) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
registerIterator(AbstractIterator< TYPE > iterator) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
returnLoan(Object sampleSeqHolder, DDS.SampleInfoSeqHolder infoSeqHolder) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
select() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
selector | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | protected |
setListener(DataReaderListener< TYPE > listener) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
setListener(DataReaderListener< TYPE > listener, Collection< Class<? extends Status >> statuses) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
setListener(DataReaderListener< TYPE > listener, Class<? extends Status >... statuses) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
setProperty(String key, String value) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
setQos(DataReaderQos qos) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
take() | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
take(int maxSamples) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
take(org.omg.dds.sub.DataReader.Selector< TYPE > query) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
take(List< Sample< TYPE >> samples) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
take(List< Sample< TYPE >> samples, org.omg.dds.sub.DataReader.Selector< TYPE > selector) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
takeNextSample(Sample< PROTOBUF_TYPE > sample) | org.opensplice.dds.sub.DataReaderProtobuf< PROTOBUF_TYPE, DDS_TYPE > | |
topicDescription | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | protected |
waitForHistoricalData(Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |
waitForHistoricalData(ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< PROTOBUF_TYPE > | |