19 #ifndef INCLUDE_SAMPLESINK_H 20 #define INCLUDE_SAMPLESINK_H 38 const QThread*
getThread()
const {
return m_thread; }
57 virtual void start() = 0;
58 virtual void stop() = 0;
59 virtual void feed(
const SampleVector::const_iterator& begin,
const SampleVector::const_iterator& end,
bool positiveOnly) = 0;
60 virtual bool handleMessage(
const Message& cmd) = 0;
71 void handleInputMessages();
74 #endif // INCLUDE_SAMPLESINK_H
const QThread * getThread() const
MsgThreadedSink(const QThread *thread)
MessageQueue * getInputMessageQueue()
Get the queue for asynchronous inbound communication.
MessageQueue m_inputMessageQueue
Queue for asynchronous inbound communication.
MessageQueue * m_guiMessageQueue
Input message queue to the GUI.
virtual void setMessageQueueToGUI(MessageQueue *queue)
#define MESSAGE_CLASS_DECLARATION
MessageQueue * getMessageQueueToGUI()
static MsgThreadedSink * create(const QThread *thread)