synchronizer.hpp

Go to the documentation of this file.

#ifndef IROHA_SYNCHRONIZER_HPP
#define IROHA_SYNCHRONIZER_HPP

#include <rxcpp/rx-observable-fwd.hpp>

#include "consensus/gate_object.hpp"
#include "synchronizer/synchronizer_common.hpp"

namespace iroha {
  namespace synchronizer {
    class Synchronizer {
     public:
      virtual void processOutcome(consensus::GateObject object) = 0;

      virtual rxcpp::observable<SynchronizationEvent> on_commit_chain() = 0;

      virtual ~Synchronizer() = default;
    };

  }  // namespace synchronizer
}  // namespace iroha
#endif  // IROHA_SYNCHRONIZER_HPP