hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
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 >:
Collaboration graph

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_typeobserver_type
 
typedef std::shared_ptr< timeout_subscriber_valuesstate_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_typemake (dest_type d, timeout_values v)
 

Public Attributes

state_type state
 

Member Typedef Documentation

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
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
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
template<class T , class Selector , class Coordination >
template<class Subscriber >
typedef timeout_observer<Subscriber> iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::this_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

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

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:

template<class T , class Selector , class Coordination >
template<class Subscriber >
void iroha::timeout< T, Selector, Coordination >::timeout_observer< Subscriber >::on_completed ( ) const
inline
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

Here is the call graph for this function:

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
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

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: