ace_analytic_merge.h

#ifndef ACE_ANALYTIC_MERGE_H
#define ACE_ANALYTIC_MERGE_H
#include "ace_analytic_abstractmanager.h"
#include "ace_analytic_abstractinput.h"
//



namespace Ace
{
   namespace Analytic
   {
      class Merge : public AbstractManager, public AbstractInput
      {
         Q_OBJECT
      public:
         virtual bool isFinished() const override final;
      public:
         explicit Merge(quint16 type, int size);
      protected:
         virtual int index() const override final;
         virtual void writeResult(std::unique_ptr<EAbstractAnalytic::Block>&& result) override final;
      protected slots:
         virtual void start() override final;
         void process();
      private:
         void readChunk(int index);
         void readBlock(QDataStream& stream);
         int _size;
         int _chunkSize;
         int _nextResult {0};
      };
   }
}



#endif