Line data    Source code

       1             : /**
       2             :  * Copyright Soramitsu Co., Ltd. All Rights Reserved.
       3             :  * SPDX-License-Identifier: Apache-2.0
       4             :  */
       5             : 
       6             : #include "multi_sig_transactions/mst_processor.hpp"
       7             : 
       8             : namespace iroha {
       9             : 
      10             :   MstProcessor::MstProcessor() : log_(logger::log("MstProcessor")) {}
      11             : 
      12             :   void MstProcessor::propagateBatch(const DataType &batch) {
      13          23 :     this->propagateBatchImpl(batch);
      14          23 :   }
      15             : 
      16             :   rxcpp::observable<std::shared_ptr<MstState>> MstProcessor::onStateUpdate()
      17             :       const {
      18         520 :     return this->onStateUpdateImpl();
      19           0 :   }
      20             : 
      21             :   rxcpp::observable<DataType> MstProcessor::onPreparedBatches() const {
      22         520 :     return this->onPreparedBatchesImpl();
      23           0 :   }
      24             : 
      25             :   rxcpp::observable<DataType> MstProcessor::onExpiredBatches() const {
      26         520 :     return this->onExpiredBatchesImpl();
      27           0 :   }
      28             : }  // namespace iroha