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         261 :         : worker_(worker), subject_(worker_) {}
      12             : 
      13             :     void StatusBusImpl::publish(StatusBus::Objects resp) {
      14        2944 :       subject_.get_subscriber().on_next(resp);
      15        2944 :     }
      16             : 
      17             :     rxcpp::observable<StatusBus::Objects> StatusBusImpl::statuses() {
      18        1279 :       return subject_.get_observable();
      19           0 :     }
      20             :   }  // namespace torii
      21             : }  // namespace iroha