ADTF
Loading...
Searching...
No Matches
adtf::streaming::flash::cExternalQueuesWrapper Class Reference

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

Public Member Functions

void RegisterExternalQueue (ISampleReaderQueue *pExternalBuffer)
 
void UnregisterExternalQueue (ISampleReaderQueue *pExternalBuffer)
 
tResult Push (const IStreamItem &oStreamItem, tTimeStamp tsTime) override
 Push a new value to the internal sample queue.
 
void Clear () override
 
tResult Pop (IStreamItem &) override
 Returns the next sample from the queue.
 

Protected Attributes

std::set< ISampleReaderQueue * > m_oExternalQueues
 A set of other registered buffer.
 

Member Function Documentation

◆ Clear()

void adtf::streaming::flash::cExternalQueuesWrapper::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::flash::cExternalQueuesWrapper::Pop ( IStreamItem & oStreamItem)
inlineoverridevirtual

Returns the next sample from the queue.

Parameters
[out]oStreamItemstream item reference to copy the references to

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

◆ Push()

tResult adtf::streaming::flash::cExternalQueuesWrapper::Push ( const IStreamItem & oStreamItem,
tTimeStamp tmTime )
inlineoverridevirtual

Push a new value to the internal sample queue.

Parameters
[in]oStreamItemThe sample to store
[in]tmTimeTime of storage

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


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