ADTF
3.18.2
|
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. More... | |
tResult | Pop (IStreamItem &oStreamItem) override |
Returns the next sample from the queue. More... | |
void | Clear () override |
clears the local queue of the reader either only EndStreaming or incoming event ISampleInStream::IQueueItem::RE_Flush | |
size_t | IsEmpty () |
ISampleReader & | GetReader () |
Private Attributes | |
cStreamItem | m_oLastReadSampleStreamItem |
std::recursive_mutex | m_oQueueMutex |
std::deque< cStreamItem > | m_oItems |
ISampleReader & | m_oSampleReader |
Definition at line 331 of file sample_collectors.h.
|
overridevirtual |
Returns the next sample from the queue.
[out] | oStreamItem | stream item reference to copy the references to |
Implements ISampleReaderQueue.
|
overridevirtual |
Push a new value to the internal sample queue.
[in] | oStreamItem | The sample to store |
[in] | tmTime | Time of storage |
Implements ISampleReaderQueue.