hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber > Struct Template Reference

#include "delay.hpp"

Collaboration diagram for iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >:
Collaboration graph

Classes

struct  delay_subscriber_values
 

Public Types

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

Public Member Functions

 delay_observer (rxcpp::composite_subscription cs, dest_type d, delay_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 rxcpp::subscriber< T, observer_typemake (dest_type d, delay_values v)
 

Public Attributes

std::shared_ptr< delay_subscriber_valuesstate
 

Member Typedef Documentation

template<class T , class Selector , class Coordination >
template<class Subscriber >
typedef rxcpp::util::decay_t<Subscriber> iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::dest_type
template<class T , class Selector , class Coordination >
template<class Subscriber >
typedef rxcpp::observer<T, this_type> iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::observer_type
template<class T , class Selector , class Coordination >
template<class Subscriber >
typedef delay_observer<Subscriber> iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::this_type
template<class T , class Selector , class Coordination >
template<class Subscriber >
typedef rxcpp::util::decay_t<T> iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::value_type

Constructor & Destructor Documentation

template<class T , class Selector , class Coordination >
template<class Subscriber >
iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::delay_observer ( rxcpp::composite_subscription  cs,
dest_type  d,
delay_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::delay< T, Selector, Coordination >::delay_observer< Subscriber >::make ( dest_type  d,
delay_values  v 
)
inlinestatic

Here is the caller graph for this function:

template<class T , class Selector , class Coordination >
template<class Subscriber >
void iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::on_completed ( ) const
inline
template<class T , class Selector , class Coordination >
template<class Subscriber >
void iroha::delay< T, Selector, Coordination >::delay_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::delay< T, Selector, Coordination >::delay_observer< Subscriber >::on_next ( Value &&  v) const
inline

Member Data Documentation

template<class T , class Selector , class Coordination >
template<class Subscriber >
std::shared_ptr<delay_subscriber_values> iroha::delay< T, Selector, Coordination >::delay_observer< Subscriber >::state

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