hsubtracter.h

#ifndef __HSUBTRACTER_H
#define __HSUBTRACTER_H
 
template <class T>
class HSubtracter : public HReader<T>, public HWriter<T>, public HWriterConsumer<T>
{
    private:
 
        HReader<T>* _reader_1;
        HReader<T>* _reader_2;
        HWriter<T>* _writer;
        bool _wait;
 
        int _blocksize;
        T* _buffer_1;
        T* _buffer_2;
 
        HProbe<T>* _probe;
 
        bool _started;
 
    public:
 
        HSubtracter(HReader<T>* reader_1, HReader<T>* reader_2, size_t blocksize, HProbe<T>* probe = NULL);
 
        HSubtracter(HReader<T>* reader, HWriter<T>* writer, size_t blocksize, HProbe<T>* probe = NULL);
 
        HSubtracter(HWriter<T>* writer, size_t blocksize, HProbe<T>* probe = NULL);
 
        HSubtracter(HReader<T>* reader, HWriterConsumer<T>* consumer, size_t blocksize, HProbe<T>* probe = NULL);
 
        HSubtracter(HWriterConsumer<T>* consumer, size_t blocksize, HProbe<T>* probe = NULL);
 
        ~HSubtracter();
 
        void Init(size_t blocksize);
 
        int Read(T* dest, size_t blocksize);
 
        int Write(T* src, size_t blocksize);
 
        bool Start();
 
        bool Stop();
 
        void SetWriter(HWriter<T>* writer)
        {
            _writer = writer;
        }
 
        bool Command(HCommand* command) {
            if( _writer != nullptr )
            {
                if (!_writer->Command(command)) {
                    return false;
                }
            }
            if( _reader_1 != nullptr )
            {
                if (!_reader_1->Command(command)) {
                    return false;
                }
            }
            if( _reader_2 != nullptr )
            {
                if( !_reader_2->Command(command) ) {
                    return false;
                }
            }
            return true;
        }
};
 
#endif