RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
Classes | Public Types | Public Member Functions | Static Public Attributes | List of all members
rxcpp::schedulers::test Class Reference

#include <rx-test.hpp>

Inheritance diagram for rxcpp::schedulers::test:
Inheritance graph
[legend]
Collaboration diagram for rxcpp::schedulers::test:
Collaboration graph
[legend]

Classes

struct  messages
 
class  test_worker
 

Public Types

typedef detail::test_type::clock_type clock_type
 
- Public Types inherited from rxcpp::schedulers::scheduler
typedef scheduler_base::clock_type clock_type
 
- Public Types inherited from rxcpp::schedulers::scheduler_base
typedef std::chrono::steady_clock clock_type
 
typedef tag_scheduler scheduler_tag
 

Public Member Functions

 test (std::shared_ptr< detail::test_type > t)
 
clock_type::time_point now () const
 
test_worker create_worker (composite_subscription cs=composite_subscription()) const
 
bool is_enabled () const
 
long clock () const
 
clock_type::time_point to_time_point (long absolute) const
 
template<class T >
rxt::testable_observable< T > make_hot_observable (std::vector< rxn::recorded< std::shared_ptr< rxn::detail::notification_base< T >>>> messages) const
 
template<class T , std::size_t size>
auto make_hot_observable (const T(&arr)[size]) const -> decltype(tester->make_hot_observable(std::vector< T >()))
 
template<class T >
auto make_hot_observable (std::initializer_list< T > il) const -> decltype(tester->make_hot_observable(std::vector< T >()))
 
template<class T >
rxt::testable_observable< T > make_cold_observable (std::vector< rxn::recorded< std::shared_ptr< rxn::detail::notification_base< T >>>> messages) const
 
template<class T , std::size_t size>
auto make_cold_observable (const T(&arr)[size]) const -> decltype(tester->make_cold_observable(std::vector< T >()))
 
template<class T >
auto make_cold_observable (std::initializer_list< T > il) const -> decltype(tester->make_cold_observable(std::vector< T >()))
 
- Public Member Functions inherited from rxcpp::schedulers::scheduler
 scheduler ()
 
 scheduler (detail::scheduler_interface_ptr i)
 
 scheduler (detail::const_scheduler_interface_ptr i)
 
clock_type::time_point now () const
 return the current time for this scheduler More...
 
worker create_worker (composite_subscription cs=composite_subscription()) const
 

Static Public Attributes

static const long created_time = 100
 
static const long subscribed_time = 200
 
static const long unsubscribed_time = 1000
 

Member Typedef Documentation

typedef detail::test_type::clock_type rxcpp::schedulers::test::clock_type

Constructor & Destructor Documentation

rxcpp::schedulers::test::test ( std::shared_ptr< detail::test_type >  t)
inlineexplicit

Member Function Documentation

long rxcpp::schedulers::test::clock ( ) const
inline
test_worker rxcpp::schedulers::test::create_worker ( composite_subscription  cs = composite_subscription()) const
inline
bool rxcpp::schedulers::test::is_enabled ( ) const
inline
template<class T >
rxt::testable_observable<T> rxcpp::schedulers::test::make_cold_observable ( std::vector< rxn::recorded< std::shared_ptr< rxn::detail::notification_base< T >>>>  messages) const
inline
template<class T , std::size_t size>
auto rxcpp::schedulers::test::make_cold_observable ( const T(&)  arr[size]) const -> decltype(tester->make_cold_observable(std::vector<T>()))
inline
template<class T >
auto rxcpp::schedulers::test::make_cold_observable ( std::initializer_list< T >  il) const -> decltype(tester->make_cold_observable(std::vector<T>()))
inline
template<class T >
rxt::testable_observable<T> rxcpp::schedulers::test::make_hot_observable ( std::vector< rxn::recorded< std::shared_ptr< rxn::detail::notification_base< T >>>>  messages) const
inline
template<class T , std::size_t size>
auto rxcpp::schedulers::test::make_hot_observable ( const T(&)  arr[size]) const -> decltype(tester->make_hot_observable(std::vector<T>()))
inline
template<class T >
auto rxcpp::schedulers::test::make_hot_observable ( std::initializer_list< T >  il) const -> decltype(tester->make_hot_observable(std::vector<T>()))
inline
clock_type::time_point rxcpp::schedulers::test::now ( ) const
inline
clock_type::time_point rxcpp::schedulers::test::to_time_point ( long  absolute) const
inline

Member Data Documentation

const long rxcpp::schedulers::test::created_time = 100
static
const long rxcpp::schedulers::test::subscribed_time = 200
static
const long rxcpp::schedulers::test::unsubscribed_time = 1000
static

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