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

#include "delay.hpp"

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

Classes

struct  delay_observer
 
struct  delay_values
 

Public Types

typedef rxcpp::util::decay_t< T > source_value_type
 
typedef rxcpp::util::decay_t< Coordination > coordination_type
 
typedef coordination_type::coordinator_type coordinator_type
 
typedef rxcpp::util::decay_t< Selector > select_type
 

Public Member Functions

 delay (select_type s, coordination_type coordination)
 
template<class Subscriber >
auto operator() (Subscriber dest) const -> decltype(delay_observer< Subscriber >::make(std::move(dest), initial))
 

Public Attributes

delay_values initial
 

Detailed Description

template<class T, class Selector, class Coordination>
struct iroha::delay< T, Selector, Coordination >

This class is mostly the same as rxcpp::operators::delay, the only change is that it accepts a selector lambda which generates a duration based on observable value instead of a fixed duration Return an observable that emits each item emitted by the source observable after the specified delay Delay is generated with selector from the last received value

Template Parameters
Tvalue type
Selectorthe type of the transforming function which returns time interval
Coordinationthe type of the scheduler

Member Typedef Documentation

template<class T , class Selector , class Coordination >
typedef rxcpp::util::decay_t<Coordination> iroha::delay< T, Selector, Coordination >::coordination_type
template<class T , class Selector , class Coordination >
typedef coordination_type::coordinator_type iroha::delay< T, Selector, Coordination >::coordinator_type
template<class T , class Selector , class Coordination >
typedef rxcpp::util::decay_t<Selector> iroha::delay< T, Selector, Coordination >::select_type
template<class T , class Selector , class Coordination >
typedef rxcpp::util::decay_t<T> iroha::delay< T, Selector, Coordination >::source_value_type

Constructor & Destructor Documentation

template<class T , class Selector , class Coordination >
iroha::delay< T, Selector, Coordination >::delay ( select_type  s,
coordination_type  coordination 
)
inline

Member Function Documentation

template<class T , class Selector , class Coordination >
template<class Subscriber >
auto iroha::delay< T, Selector, Coordination >::operator() ( Subscriber  dest) const -> decltype(delay_observer<Subscriber>::make(std::move(dest), initial))
inline

Here is the call graph for this function:

Member Data Documentation

template<class T , class Selector , class Coordination >
delay_values iroha::delay< T, Selector, Coordination >::initial

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