RTI Connext C# API Version 7.3.0
|
The base of a typed DataReader<T>. Provides type-independent methods and properties. More...
Public Member Functions | |
ReadCondition | CreateReadCondition (DataState state) |
Creates a ReadCondition. More... | |
QueryCondition | CreateQueryCondition (Filter filter, DataState state) |
Creates a QueryCondition with a filter and a data state. More... | |
QueryCondition | CreateQueryCondition (Filter filter) |
Creates a QueryCondition with DataState.Any. More... | |
PublicationBuiltinTopicData | GetMatchedPublicationData (in InstanceHandle publicationHandle) |
Retrieves the information on a publication that is currently "associated" with this DataReader. More... | |
IEnumerable< PublicationBuiltinTopicData > | GetMatchedPublicationData () |
Retrieves the information on all publications that are currently "associated" with this DataReader. More... | |
ParticipantBuiltinTopicData | GetMatchedPublicationParticipantData (in InstanceHandle publicationHandle) |
Retrieves the information on the discovered Domain.DomainParticipant associated with the publication that is currently matching with the DataReader<T> More... | |
void | AcknowledgeAll () |
Acknowledges all previously accessed samples. More... | |
void | AcknowledgeAll (AckResponseData responseData) |
Acknowledges all previously accessed samples with a response. More... | |
void | AcknowledgeSample (SampleInfo sampleInfo) |
Acknowledges a single sample explicitly. More... | |
void | AcknowledgeSample (SampleInfo sampleInfo, AckResponseData responseData) |
Acknowledges a single sample explicitly with a response. More... | |
void | AcknowledgeSample (SampleIdentity sampleIdentity) |
Acknowledges a single sample explicitly. More... | |
void | AcknowledgeSample (SampleIdentity sampleIdentity, AckResponseData responseData) |
Acknowledges a single sample explicitly with a response. More... | |
DataReaderProtocolStatus | GetMatchedPublicationDataReaderProtocolStatus (in InstanceHandle publicationHandle) |
Gets the DataReaderProtocolStatus for this reader, per matched publication identified by its InstanceHandle. More... | |
bool | IsMatchedPublicationAlive (in InstanceHandle publicationHandle) |
Check if a publication currently matched with this reader is alive. More... | |
void | WaitForHistoricalData (in Duration duration) |
Waits until all "historical" data is received if the reader was configured with a non-Volatile DurabilityKind. More... | |
abstract LoanedSamples< object > | ReadUntyped () |
Allows calling DataReader<T>.Read in a context where the type is not known. More... | |
abstract LoanedSamples< object > | TakeUntyped () |
Allows calling DataReader<T>.Take in a context where the type is not known. More... | |
abstract InstanceHandle | LookupInstanceUntyped (object keyHolder) |
Allows calling DataReader<T>.LookupInstance in a context where the type is not known. More... | |
abstract object | GetKeyValueUntyped (object keyHolder, in InstanceHandle InstanceHandle) |
Allows calling DataReader<T>.GetKeyValue in a context where the type is not known. More... | |
abstract SelectorUntyped | SelectUntyped () |
Allows calling DataReader<T>.Select in a context where the type is not known. More... | |
override void | ResetEvents (StatusMask eventsToRemove=StatusMask.All) |
Stop notifying of certain events and remove their event handlers More... | |
void | DisposeContainedEntities () |
Disposes all the entities that were created by this reader. More... | |
![]() | |
void | Enable () |
Enables this Entity (by default entities are automatically enabled after creation) More... | |
abstract void | ResetEvents (StatusMask eventsToRemove=StatusMask.All) |
Stop notifying of events and remove their event handlers. The actual events are defined in each derived entity class. More... | |
EntityLock | Lock () |
Locks the Entity using its internal lock. More... | |
void | Dispose () |
Releases the resources used by this Entity and disposes its contained entities as well (if any). More... | |
The base of a typed DataReader<T>. Provides type-independent methods and properties.
ReadCondition Rti.Dds.Subscription.AnyDataReader.CreateReadCondition | ( | DataState | state | ) |
Creates a ReadCondition.
The full documentation is available in the C API: DDS_DataReader_create_readcondition
QueryCondition Rti.Dds.Subscription.AnyDataReader.CreateQueryCondition | ( | Filter | filter, |
DataState | state | ||
) |
Creates a QueryCondition with a filter and a data state.
The full documentation is available in the C API: DDS_DataReader_create_querycondition
QueryCondition Rti.Dds.Subscription.AnyDataReader.CreateQueryCondition | ( | Filter | filter | ) |
Creates a QueryCondition with DataState.Any.
The full documentation is available in the C API: DDS_DataReader_create_querycondition
PublicationBuiltinTopicData Rti.Dds.Subscription.AnyDataReader.GetMatchedPublicationData | ( | in InstanceHandle | publicationHandle | ) |
Retrieves the information on a publication that is currently "associated" with this DataReader.
The full documentation is available in the C API: DDS_DataReader_get_matched_publication_data
|
inline |
Retrieves the information on all publications that are currently "associated" with this DataReader.
ParticipantBuiltinTopicData Rti.Dds.Subscription.AnyDataReader.GetMatchedPublicationParticipantData | ( | in InstanceHandle | publicationHandle | ) |
Retrieves the information on the discovered Domain.DomainParticipant associated with the publication that is currently matching with the DataReader<T>
The full documentation is available in the C API: DDS_DataReader_get_matched_publication_participant_data
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeAll | ( | ) |
Acknowledges all previously accessed samples.
The full documentation is available in the C API: DDS_DataReader_acknowledge_all
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeAll | ( | AckResponseData | responseData | ) |
Acknowledges all previously accessed samples with a response.
The full documentation is available in the C API: DDS_DataReader_acknowledge_all_w_response
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeSample | ( | SampleInfo | sampleInfo | ) |
Acknowledges a single sample explicitly.
The full documentation is available in the C API: DDS_DataReader_acknowledge_sample
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeSample | ( | SampleInfo | sampleInfo, |
AckResponseData | responseData | ||
) |
Acknowledges a single sample explicitly with a response.
The full documentation is available in the C API: DDS_DataReader_acknowledge_sample_w_response
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeSample | ( | SampleIdentity | sampleIdentity | ) |
Acknowledges a single sample explicitly.
The SampleIdentity from a specific LoanedSample<T> can be obtained from its SampleInfo. This method is equivalent to AcknowledgeSample(SampleInfo), but can be used with a previously stored SampleIdentity when the specific LoanedSample<T> has already been disposed.
void Rti.Dds.Subscription.AnyDataReader.AcknowledgeSample | ( | SampleIdentity | sampleIdentity, |
AckResponseData | responseData | ||
) |
Acknowledges a single sample explicitly with a response.
The SampleIdentity from a specific LoanedSample<T> can be obtained from its SampleInfo. This method is equivalent to AcknowledgeSample(SampleInfo, AckResponseData), but can be used with a previously stored SampleIdentity when the specific LoanedSample<T> has already been disposed.
DataReaderProtocolStatus Rti.Dds.Subscription.AnyDataReader.GetMatchedPublicationDataReaderProtocolStatus | ( | in InstanceHandle | publicationHandle | ) |
Gets the DataReaderProtocolStatus for this reader, per matched publication identified by its InstanceHandle.
The full documentation is available in the C API: DDS_DataReader_get_matched_publication_datareader_protocol_status
bool Rti.Dds.Subscription.AnyDataReader.IsMatchedPublicationAlive | ( | in InstanceHandle | publicationHandle | ) |
Check if a publication currently matched with this reader is alive.
The full documentation is available in the C API: DDS_DataReader_is_matched_publication_alive
void Rti.Dds.Subscription.AnyDataReader.WaitForHistoricalData | ( | in Duration | duration | ) |
Waits until all "historical" data is received if the reader was configured with a non-Volatile DurabilityKind.
The full documentation is available in the C API: DDS_DataReader_wait_for_historical_data
|
pure virtual |
Allows calling DataReader<T>.Read in a context where the type is not known.
Implemented in Rti.Dds.Subscription.DataReader< T >.
|
pure virtual |
Allows calling DataReader<T>.Take in a context where the type is not known.
Implemented in Rti.Dds.Subscription.DataReader< T >.
|
pure virtual |
Allows calling DataReader<T>.LookupInstance in a context where the type is not known.
Implemented in Rti.Dds.Subscription.DataReader< T >.
|
pure virtual |
Allows calling DataReader<T>.GetKeyValue in a context where the type is not known.
|
pure virtual |
Allows calling DataReader<T>.Select in a context where the type is not known.
Implemented in Rti.Dds.Subscription.DataReader< T >.
|
inlinevirtual |
Stop notifying of certain events and remove their event handlers
eventsToRemove | Selects which events will stop receiving notifications. Use StatusMask.All to remove all event handlers. |
Implements Rti.Dds.Core.Entity.
|
inline |
Disposes all the entities that were created by this reader.
The full documentation is available in the C API: DDS_DataReader_delete_contained_entities
|
getset |
Gets or sets the reader QoS.
The full documentation is available in the C API: DDS_DataReader_set_qos
|
get |
Returns the Subscriber to which the DataReader belongs.
The full documentation is available in the C API: DDS_DataReader_get_subscriber
|
get |
Returns the TopicDescription associated with this DataReader.
The full documentation is available in the C API: DDS_DataReader_get_topicdescription
|
get |
Retrieve the StatusMask.SubscriptionMatched status.
The full documentation is available in the C API: DDS_DataReader_get_subscription_matched_status
|
get |
Retrieve the StatusMask.LivelinessChanged status.
The full documentation is available in the C API: DDS_DataReader_get_liveliness_changed_status
|
get |
Retrieve the StatusMask.RequestedDeadlineMissed status.
The full documentation is available in the C API: DDS_DataReader_get_requested_deadline_missed_status
|
get |
Retrieve the StatusMask.RequestedIncompatibleQos status.
The full documentation is available in the C API: DDS_DataReader_get_requested_incompatible_qos_status
|
get |
Retrieve the StatusMask.SampleLost status.
The full documentation is available in the C API: DDS_DataReader_get_sample_lost_status
|
get |
Retrieve the StatusMask.SampleRejected status.
The full documentation is available in the C API: DDS_DataReader_get_sample_rejected_status
|
get |
Retrieve the StatusMask.DataReaderCache status.
The full documentation is available in the C API: DDS_DataReader_get_datareader_cache_status
|
get |
Retrieve the StatusMask.DataReaderProtocol status.
The full documentation is available in the C API: DDS_DataReader_get_datareader_protocol_status
|
get |
Retrieves the list of publications currently "associated" with this DataReader.
The full documentation is available in the C API: DDS_DataReader_get_matched_publications
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.SubscriptionMatched status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.DataAvailable status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.LivelinessChanged status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.RequestedDeadlineMissed status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.RequestedIncompatibleQos status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.SampleLost status changes
|
addremove |
Event triggered when the Rti.Dds.Core.Status.StatusMask.SampleRejected status changes