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

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

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

Coordination	the type of the scheduler
Selector	the type of the aggregation function
ObservableN	types of source observables

Member Typedef Documentation

coordination_type

template<class Coordination , class Selector , class... ObservableN>

typedef traits::coordination_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::coordination_type

coordinator_type

template<class Coordination , class Selector , class... ObservableN>

typedef coordination_type::coordinator_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::coordinator_type

selector_type

template<class Coordination , class Selector , class... ObservableN>

typedef traits::selector_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::selector_type

this_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

traits

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

tuple_source_type

template<class Coordination , class Selector , class... ObservableN>

typedef traits::tuple_source_type iroha::combine_latest_until_first_completed< Coordination, Selector, ObservableN >::tuple_source_type

tuple_source_value_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

combine_latest_until_first_completed()

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

on_subscribe()

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:

subscribe_all()

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:

subscribe_one()

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

initial

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:

• libs/common/combine_latest_until_first_completed.hpp