Reads and stores Samples within the given queue implementation INTERNAL_QUEUE
.
More...
#include <samplereader.h>
Protected Attributes | |
INTERNAL_QUEUE | m_oQueue |
![]() | |
std::unique_ptr< cImplementation > | m_pImplementation |
Additional Inherited Members | |
![]() | |
cSampleReader (ant::ISampleReaderQueue &oQueue, ant::ISampleStreamAccess::tMode eAccessMode, bool bStoreLastSample) | |
void | SetName (const char *strName) override |
Sets the name of the streamer. | |
tResult | GetName (base::ant::IString &&strName) override |
Retrieves the name of the streamer. | |
tResult | SetType (const ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType) override |
Sets the initial stream type of a streamer. | |
tResult | GetType (ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType) const override |
Returns the initial stream type of the streamer. | |
tResult | BeginStreaming (ISampleStream &oSampleStream) override |
Begin streaming on the given sample stream. | |
tResult | EndStreaming () override |
End streaming. | |
tResult | SetStreamerPin (const ucom::ant::iobject_ptr< IStreamerPin > &pStreamerPin) override |
Sets the pin that the streamer is associated with. | |
void | SetAcceptTypeCallback (const std::function< tResult(const ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType)> &fnAcceptTypeCallback) |
Sets a callback function which is called while a Stream Type is received - see also AcceptType and IsCompatible implementations. | |
void | SetStreamErrorCallback (const std::function< tResult(tResult oStreamError)> &fnStreamErrorCallback) |
A callback function to react on stream errors. | |
tResult | SetStreamError (tResult oError) override |
Sets an error on the associated sample stream. | |
tResult | GetLastType (ucom::ant::iobject_ptr< const ant::IStreamType > &pType) override |
Returns the last stream type that was read from the sample stream. | |
tResult | GetNextSample (ucom::ant::iobject_ptr< const ant::ISample > &pSample) override |
Reads the next available sample from the associated sample stream. | |
tResult | GetLastSample (ucom::ant::iobject_ptr< const ant::ISample > &pSample) override |
Reads the latest available sample from the associated sample stream. | |
void | Reset () |
tResult | ReadAllAvailableItems () override |
Reads all available items from the sample stream into internal queues. | |
tResult | RequestSamples (ucom::ant::iobject_ptr< hollow::IStreamingRequest > &pRequest, uint32_t nSubStreamId, const base::ant::IProperties *pRequestProperties=nullptr) |
RequestSamples of the given Substream to be generated and/or transmitted. | |
void | SetSynchronousTypeUpdateCallback (const std::function< tResult(const ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType)> &fnRequestTypeUpdateCallback) |
Reads and stores Samples within the given queue implementation INTERNAL_QUEUE
.
INTERNAL_QUEUE | Queue implematation class which must support the ISampleReaderQueue interface. |
STORE_LAST_SAMPLE | true/false value to define if GetLastSample always return the last incoming sample, to (default is true ) |
ACCESS_MODE | Mode for access the ISampleStream (default is PushRead) |
Definition at line 1011 of file samplereader.h.
|
inline |
Definition at line 1017 of file samplereader.h.
|
protected |
Definition at line 1014 of file samplereader.h.