adtf::streaming::flash::detail::cExternalSampleReaderQueue Class Reference

Inherits adtf::streaming::ant::ISampleReaderQueue.

Public Member Functions
	cExternalSampleReaderQueue (ISampleReader &oSampleReader)
tResult	GetSampleBeforeOrAt (tTimeStamp tmTime, adtf::ucom::iobject_ptr< const ant::ISample > &pSample, adtf::ucom::iobject_ptr< const ant::IStreamType > &pStreamType)
tResult	GetNextSampleAndType (adtf::ucom::iobject_ptr< const ant::ISample > &pSample, adtf::ucom::iobject_ptr< const ant::IStreamType > &pStreamType)
tResult	Push (const IStreamItem &oStreamItem, tTimeStamp tmTime) override
	Push a new value to the internal sample queue.
tResult	Pop (IStreamItem &oStreamItem) override
	Returns the next sample from the queue.
void	Clear () override
size_t	IsEmpty ()
ISampleReader &	GetReader ()

Member Function Documentation

Clear()

void adtf::streaming::flash::detail::cExternalSampleReaderQueue::Clear ( )

overridevirtual

clears the local queue of the reader either only EndStreaming or incoming event ISampleInStream::IQueueItem::RE_Flush

Implements adtf::streaming::ant::ISampleReaderQueue.

Pop()

tResult adtf::streaming::flash::detail::cExternalSampleReaderQueue::Pop ( IStreamItem & oStreamItem )

overridevirtual

Returns the next sample from the queue.

Parameters

[out]

oStreamItem

stream item reference to copy the references to

Implements adtf::streaming::ant::ISampleReaderQueue.

Push()

tResult adtf::streaming::flash::detail::cExternalSampleReaderQueue::Push ( const IStreamItem & oStreamItem, tTimeStamp tmTime )

overridevirtual

Push a new value to the internal sample queue.

Parameters

[in]	oStreamItem	The sample to store
[in]	tmTime	Time of storage

Implements adtf::streaming::ant::ISampleReaderQueue.

---

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

• src/libraries/streaming3/include/adtfstreaming3/sample_collectors.h