Reads and stores Samples within the given queue implementation INTERNAL_QUEUE. More...

#include <samplereader.h>

Inherits adtf::streaming::flash::cSampleReader.

Protected Attributes
INTERNAL_QUEUE	m_oQueue

Protected Attributes inherited from adtf::streaming::flash::cSampleReader
std::unique_ptr< cImplementation >	m_pImplementation

Additional Inherited Members
Public Member Functions inherited from adtf::streaming::flash::cSampleReader
	cSampleReader (ant::ISampleReaderQueue &oQueue, ant::ISampleStreamAccess::tMode eAccessMode, bool bStoreLastSample)

void	SetName (const char *strName) override

tResult	GetName (base::ant::IString &&strName) override

tResult	SetType (const ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType) override

tResult	GetType (ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType) const override

tResult	BeginStreaming (ISampleStream &oSampleStream) override

tResult	EndStreaming () override

tResult	SetStreamerPin (const ucom::ant::iobject_ptr< IStreamerPin > &pStreamerPin) override

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.

void	SetStreamErrorCallback (const std::function< tResult(tResult oStreamError)> &fnStreamErrorCallback)
	A callback function to react on stream errors.

tResult	SetStreamError (tResult oError) override

tResult	GetLastType (ucom::ant::iobject_ptr< const ant::IStreamType > &pType) override

tResult	GetNextSample (ucom::ant::iobject_ptr< const ant::ISample > &pSample) override

tResult	GetLastSample (ucom::ant::iobject_ptr< const ant::ISample > &pSample) override

void	Reset ()

tResult	ReadAllAvailableItems () override

tResult	RequestSamples (ucom::ant::iobject_ptr< hollow::IStreamingRequest > &pRequest, uint32_t nSubStreamId, const base::ant::IProperties *pRequestProperties=nullptr)

void	SetSynchronousTypeUpdateCallback (const std::function< tResult(const ucom::ant::iobject_ptr< const ant::IStreamType > &pStreamType)> &fnRequestTypeUpdateCallback)

Detailed Description

template<typename INTERNAL_QUEUE, bool STORE_LAST_SAMPLE = true, ant::ISampleStreamAccess::tMode ACCESS_MODE = ant::ISampleStreamAccess::tMode::Push>
class adtf::streaming::flash::sample_reader< INTERNAL_QUEUE, STORE_LAST_SAMPLE, ACCESS_MODE >

Reads and stores Samples within the given queue implementation INTERNAL_QUEUE.

Template Parameters

INTERNAL_QUEUE	Queue implematation class which must support the adtf::streaming::ant::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 adtf::streaming::ant::ISampleStreamAccess::tMode::PushRead)

The documentation for this class was generated from the following file:

src/libraries/streaming3/include/adtfstreaming3/samplereader.h

Protected Attributes

Additional Inherited Members

Detailed Description