iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber > Struct Template Reference

#include "timeout.hpp"

Collaboration diagram for iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >:

Classes
struct	timeout_subscriber_values

Public Types
typedef timeout_observer< Subscriber >	this_type
typedef rxcpp::util::decay_t< T >	value_type
typedef rxcpp::util::decay_t< Subscriber >	dest_type
typedef rxcpp::observer< T, this_type >	observer_type
typedef std::shared_ptr< timeout_subscriber_values >	state_type

Public Member Functions
	timeout_observer (rxcpp::composite_subscription cs, dest_type d, timeout_values v, coordinator_type c)
template<class Value >
void	on_next (Value &&v) const
void	on_error (std::exception_ptr e) const
void	on_completed () const

Static Public Member Functions
static std::function< void(const rxcpp::schedulers::schedulable &)>	produce_timeout (std::size_t id, state_type state)
static rxcpp::subscriber< T, observer_type >	make (dest_type d, timeout_values v)

Public Attributes
state_type	state

Member Typedef Documentation

dest_type

template<class T , class Selector , class Coordination >

template<class Subscriber >

typedef rxcpp::util::decay_t<Subscriber> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::dest_type

observer_type

template<class T , class Selector , class Coordination >

template<class Subscriber >

typedef rxcpp::observer<T, this_type> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::observer_type

state_type

template<class T , class Selector , class Coordination >

template<class Subscriber >

typedef std::shared_ptr<timeout_subscriber_values> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::state_type

this_type

template<class T , class Selector , class Coordination >

template<class Subscriber >

typedef timeout_observer<Subscriber> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::this_type

value_type

template<class T , class Selector , class Coordination >

template<class Subscriber >

typedef rxcpp::util::decay_t<T> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::value_type

Constructor & Destructor Documentation

timeout_observer()

template<class T , class Selector , class Coordination >

template<class Subscriber >

iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::timeout_observer ( rxcpp::composite_subscription  cs, dest_type  d, timeout_values  v, coordinator_type  c  )

inline

Member Function Documentation

make()

template<class T , class Selector , class Coordination >

template<class Subscriber >

static rxcpp::subscriber<T, observer_type> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::make ( dest_type  d, timeout_values  v  )

inlinestatic

Here is the caller graph for this function:

on_completed()

template<class T , class Selector , class Coordination >

template<class Subscriber >

void iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::on_completed ( ) const

inline

on_error()

template<class T , class Selector , class Coordination >

template<class Subscriber >

void iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::on_error ( std::exception_ptr  e ) const

inline

on_next()

template<class T , class Selector , class Coordination >

template<class Subscriber >

template<class Value >

void iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::on_next ( Value &&  v ) const

inline

produce_timeout()

template<class T , class Selector , class Coordination >

template<class Subscriber >

static std::function<void(const rxcpp::schedulers::schedulable &)> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::produce_timeout ( std::size_t  id, state_type  state  )

inlinestatic

Member Data Documentation

state

template<class T , class Selector , class Coordination >

template<class Subscriber >

state_type iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::state

---

The documentation for this struct was generated from the following file:

• libs/common/timeout.hpp