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