hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
iroha::torii::StatusBusImpl Class Reference

#include "status_bus_impl.hpp"

Inheritance diagram for iroha::torii::StatusBusImpl:
Inheritance graph
Collaboration diagram for iroha::torii::StatusBusImpl:
Collaboration graph

Public Member Functions

 StatusBusImpl (rxcpp::observe_on_one_worker worker=rxcpp::observe_on_new_thread())
 
 ~StatusBusImpl () override
 
void publish (StatusBus::Objects) override
 
rxcpp::observable< StatusBus::Objectsstatuses () override
 Subscribers will be invoked in separate thread. More...
 
- Public Member Functions inherited from iroha::torii::StatusBus
virtual ~StatusBus ()=default
 

Public Attributes

rxcpp::observe_on_one_worker worker_
 
rxcpp::composite_subscription cs_
 
rxcpp::subjects::synchronize< StatusBus::Objects, decltype(worker_)> subject_
 

Additional Inherited Members

- Public Types inherited from iroha::torii::StatusBus
using Objects = std::shared_ptr< shared_model::interface::TransactionResponse >
 Objects that represent status to operate with. More...
 

Detailed Description

StatusBus implementation

Constructor & Destructor Documentation

iroha::torii::StatusBusImpl::StatusBusImpl ( rxcpp::observe_on_one_worker  worker = rxcpp::observe_on_new_thread())
iroha::torii::StatusBusImpl::~StatusBusImpl ( )
override

Member Function Documentation

void iroha::torii::StatusBusImpl::publish ( StatusBus::Objects  )
overridevirtual

Shares object among the bus subscribers

Parameters
objectto share note: guaranteed to be non-blocking call

Implements iroha::torii::StatusBus.

rxcpp::observable< StatusBus::Objects > iroha::torii::StatusBusImpl::statuses ( )
overridevirtual

Subscribers will be invoked in separate thread.

Implements iroha::torii::StatusBus.

Member Data Documentation

rxcpp::composite_subscription iroha::torii::StatusBusImpl::cs_
rxcpp::subjects::synchronize<StatusBus::Objects, decltype(worker_)> iroha::torii::StatusBusImpl::subject_
rxcpp::observe_on_one_worker iroha::torii::StatusBusImpl::worker_

The documentation for this class was generated from the following files: