iroha::torii::StatusBusImpl Class Reference

#include "status_bus_impl.hpp"

Inheritance diagram for iroha::torii::StatusBusImpl:

Collaboration diagram for iroha::torii::StatusBusImpl:

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::Objects >	statuses () 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

StatusBusImpl()

iroha::torii::StatusBusImpl::StatusBusImpl

(

rxcpp::observe_on_one_worker

worker = rxcpp::observe_on_new_thread()

)

~StatusBusImpl()

iroha::torii::StatusBusImpl::~StatusBusImpl ( )

override

Member Function Documentation

publish()

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

overridevirtual

Shares object among the bus subscribers

Parameters

object

to share note: guaranteed to be non-blocking call

Implements iroha::torii::StatusBus.

statuses()

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

overridevirtual

Subscribers will be invoked in separate thread.

Implements iroha::torii::StatusBus.

Member Data Documentation

cs_

rxcpp::composite_subscription iroha::torii::StatusBusImpl::cs_

subject_

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

worker_

rxcpp::observe_on_one_worker iroha::torii::StatusBusImpl::worker_

---

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

• irohad/torii/impl/status_bus_impl.hpp
• irohad/torii/impl/status_bus_impl.cpp