Line data    Source code

       1             : /**
       2             :  * Copyright Soramitsu Co., Ltd. All Rights Reserved.
       3             :  * SPDX-License-Identifier: Apache-2.0
       4             :  */
       5             : 
       6             : #include "torii/impl/status_bus_impl.hpp"
       7             : 
       8             : namespace iroha {
       9             :   namespace torii {
      10             :     StatusBusImpl::StatusBusImpl(rxcpp::observe_on_one_worker worker)
      11         250 :         : worker_(worker), subject_(worker_, cs_) {}
      12             : 
      13             :     StatusBusImpl::~StatusBusImpl() {
      14         250 :       cs_.unsubscribe();
      15         250 :     }
      16             : 
      17             :     void StatusBusImpl::publish(StatusBus::Objects resp) {
      18        2989 :       subject_.get_subscriber().on_next(resp);
      19        2989 :     }
      20             : 
      21             :     rxcpp::observable<StatusBus::Objects> StatusBusImpl::statuses() {
      22        1283 :       return subject_.get_observable();
      23           0 :     }
      24             :   }  // namespace torii
      25             : }  // namespace iroha