hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN > Struct Template Reference

#include "combine_latest_until_first_completed.hpp"

Inheritance diagram for iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >:
Inheritance graph
Collaboration diagram for iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >:
Collaboration graph

Classes

struct  values
 

Public Types

typedef combine_latest_until_first_completed< Coordination, Selector, ObservableN... > this_type
 
typedef rxcpp::operators::detail::combine_latest_traits< Coordination, Selector, ObservableN... > traits
 
typedef traits::tuple_source_type tuple_source_type
 
typedef traits::tuple_source_value_type tuple_source_value_type
 
typedef traits::selector_type selector_type
 
typedef traits::coordination_type coordination_type
 
typedef coordination_type::coordinator_type coordinator_type
 

Public Member Functions

 combine_latest_until_first_completed (coordination_type sf, selector_type s, tuple_source_type ts)
 
template<int Index, class State >
void subscribe_one (std::shared_ptr< State > state) const
 
template<class State , int... IndexN>
void subscribe_all (std::shared_ptr< State > state, rxcpp::util::values< int, IndexN... >) const
 
template<class Subscriber >
void on_subscribe (Subscriber scbr) const
 

Public Attributes

values initial
 

Detailed Description

template<class Coordination, class Selector, class... ObservableN>
struct iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >

This class is mostly the same as rxcpp::operators::combine_latest, the only change is that it completes when the first of observables is completed instead of all observables For each item from all of the observables select a value to emit from the new observable that is returned

Template Parameters
Coordinationthe type of the scheduler
Selectorthe type of the aggregation function
ObservableNtypes of source observables

Member Typedef Documentation

template<class Coordination , class Selector , class... ObservableN>
typedef traits::coordination_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::coordination_type
template<class Coordination , class Selector , class... ObservableN>
typedef coordination_type::coordinator_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::coordinator_type
template<class Coordination , class Selector , class... ObservableN>
typedef traits::selector_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::selector_type
template<class Coordination , class Selector , class... ObservableN>
typedef combine_latest_until_first_completed<Coordination, Selector, ObservableN...> iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::this_type
template<class Coordination , class Selector , class... ObservableN>
typedef rxcpp::operators::detail:: combine_latest_traits<Coordination, Selector, ObservableN...> iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::traits
template<class Coordination , class Selector , class... ObservableN>
typedef traits::tuple_source_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::tuple_source_type
template<class Coordination , class Selector , class... ObservableN>
typedef traits::tuple_source_value_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::tuple_source_value_type

Constructor & Destructor Documentation

template<class Coordination , class Selector , class... ObservableN>
iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::combine_latest_until_first_completed ( coordination_type  sf,
selector_type  s,
tuple_source_type  ts 
)
inline

Member Function Documentation

template<class Coordination , class Selector , class... ObservableN>
template<class Subscriber >
void iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::on_subscribe ( Subscriber  scbr) const
inline

Here is the call graph for this function:

template<class Coordination , class Selector , class... ObservableN>
template<class State , int... IndexN>
void iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::subscribe_all ( std::shared_ptr< State >  state,
rxcpp::util::values< int, IndexN... >   
) const
inline

Here is the caller graph for this function:

template<class Coordination , class Selector , class... ObservableN>
template<int Index, class State >
void iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::subscribe_one ( std::shared_ptr< State >  state) const
inline

Here is the call graph for this function:

Member Data Documentation

template<class Coordination , class Selector , class... ObservableN>
values iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::initial

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