adtf::streaming::ant::cLimitedSampleReaderQueue Class Reference

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

Inherited by adtf::streaming::ant::size_limited_sample_reader_queue< MaxSize >, and adtf::streaming::ant::time_limited_sample_reader_queue< TimeRange >.

Public Member Functions
tResult	Push (const IStreamItem &oStreamItem, tTimeStamp) override
	Push a new value to the internal sample queue.
void	Clear () override
tResult	Pop (IStreamItem &oItem)
	Returns the next sample from the queue.

Protected Member Functions
virtual void	CheckQueue (const std::deque< cStreamItem > &oItems)=0
void	PopFront ()
size_t	GetSampleCount ()

Member Function Documentation

Clear()

void adtf::streaming::ant::cLimitedSampleReaderQueue::Clear ( )

inlineoverridevirtual

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::ant::cLimitedSampleReaderQueue::Pop ( IStreamItem & oStreamItem )

inlinevirtual

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::ant::cLimitedSampleReaderQueue::Push ( const IStreamItem & oStreamItem, tTimeStamp tmTime )

inlineoverridevirtual

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/samplereader.h