hsplitter.h

#ifndef __HSPLITTER_H
#define __HSPLITTER_H
 
#include <vector>
 
template <class T>
class HSplitter : public HWriter<T>, public HWriterConsumer<T>
{
    private:
 
        std::vector< HWriter<T>* > _writers;
 
    public:
 
        HSplitter(HWriter<T>* writer1, HWriter<T>* writer2)
        {
            HLog("HSplitter(HWriter*, HWriter*)");
            _writers.push_back(writer1);
            _writers.push_back(writer2);
        }
 
        HSplitter( std::vector< HWriter<T>* > writers)
        {
            HLog("HSplitter( std::vector< HWriter* >)");
            for( typename std::vector< HWriter<T>* >::iterator it = writers.begin(); it != writers.end(); it++ )
            {
                _writers.push_back( (*it) );
            }
        }
 
        HSplitter(HWriterConsumer<T>* consumer)
        {
            HLog("HSplitter(HWriterConsumer*)");
            consumer->SetWriter(this);
        }
 
        int Write(T* src, size_t blocksize);
 
        bool Start();
 
        bool Stop();
 
        void SetWriter(HWriter<T>* writer);
 
        bool Command(HCommand* command) {
            for( typename std::vector< HWriter<T>* >::iterator it = _writers.begin(); it != _writers.end(); it++ )
            {
                if( !(*it)->Command(command) )
                {
                    return false;
                }
            }
            return true;
        }
};
 
#endif