status_bus.hpp

Go to the documentation of this file.

#ifndef TORII_STATUS_BUS
#define TORII_STATUS_BUS

#include <rxcpp/rx-observable-fwd.hpp>
#include "interfaces/transaction_responses/tx_response.hpp"

namespace iroha {
  namespace torii {
    class StatusBus {
     public:
      virtual ~StatusBus() = default;

      using Objects =
          std::shared_ptr<shared_model::interface::TransactionResponse>;

      virtual void publish(Objects) = 0;

      virtual rxcpp::observable<Objects> statuses() = 0;
    };
  }  // namespace torii
}  // namespace iroha

#endif  // TORII_STATUS_BUS