#include <rx-test.hpp>

Inheritance diagram for rxcpp::schedulers::test::test_worker:

Collaboration diagram for rxcpp::schedulers::test::test_worker:

Classes
struct	start_traits

Public Member Functions
	~test_worker ()

	test_worker (composite_subscription cs, std::shared_ptr< detail::test_type::test_type_worker > t)

bool	is_enabled () const

long	clock () const

void	schedule_absolute (long when, const schedulable &a) const

void	schedule_relative (long when, const schedulable &a) const

template<class Arg0 , class... ArgN>
auto	schedule_absolute (long when, Arg0 &&a0, ArgN &&...an) const -> typename std::enable_if< (detail::is_action_function< Arg0 >::value\|\| is_subscription< Arg0 >::value)&& !is_schedulable< Arg0 >::value >::type

template<class Arg0 , class... ArgN>
auto	schedule_relative (long when, Arg0 &&a0, ArgN &&...an) const -> typename std::enable_if< (detail::is_action_function< Arg0 >::value\|\| is_subscription< Arg0 >::value)&& !is_schedulable< Arg0 >::value >::type

void	advance_to (long time) const

void	advance_by (long time) const

void	sleep (long time) const

template<class T , class F >
auto	start (F createSource, long created, long subscribed, long unsubscribed) const -> subscriber< T, rxt::testable_observer< T >>

template<class T , class F >
auto	start (F &&createSource, long unsubscribed) const -> subscriber< T, rxt::testable_observer< T >>

template<class T , class F >
auto	start (F &&createSource) const -> subscriber< T, rxt::testable_observer< T >>

template<class F >
auto	start (F createSource, long created, long subscribed, long unsubscribed) const -> typename std::enable_if< detail::is_create_source_function< F >::value, start_traits< F >>::type::subscriber_type

template<class F >
auto	start (F createSource, long unsubscribed) const -> typename std::enable_if< detail::is_create_source_function< F >::value, start_traits< F >>::type::subscriber_type

template<class F >
auto	start (F createSource) const -> typename std::enable_if< detail::is_create_source_function< F >::value, start_traits< F >>::type::subscriber_type

void	start () const

template<class T >
subscriber< T, rxt::testable_observer< T > >	make_subscriber () const

Public Member Functions inherited from rxcpp::schedulers::worker
	worker ()

	worker (composite_subscription cs, detail::const_worker_interface_ptr i)

	worker (composite_subscription cs, worker o)

const composite_subscription &	get_subscription () const

composite_subscription &	get_subscription ()

bool	is_subscribed () const

weak_subscription	add (subscription s) const

void	remove (weak_subscription w) const

void	clear () const

void	unsubscribe () const

clock_type::time_point	now () const
	return the current time for this worker More...

void	schedule (const schedulable &scbl) const
	insert the supplied schedulable to be run as soon as possible More...

void	schedule (clock_type::time_point when, const schedulable &scbl) const
	insert the supplied schedulable to be run at the time specified More...

void	schedule (clock_type::duration when, const schedulable &scbl) const
	insert the supplied schedulable to be run at now() + the delay specified More...

void	schedule_periodically (clock_type::time_point initial, clock_type::duration period, const schedulable &scbl) const

void	schedule_periodically (clock_type::duration initial, clock_type::duration period, const schedulable &scbl) const

template<class Arg0 , class... ArgN>
auto	schedule (Arg0 &&a0, ArgN &&...an) const -> typename std::enable_if< (detail::is_action_function< Arg0 >::value\|\| is_subscription< Arg0 >::value)&& !is_schedulable< Arg0 >::value >::type
	use the supplied arguments to make a schedulable and then insert it to be run More...

template<class... ArgN>
void	schedule_rebind (const schedulable &scbl, ArgN &&...an) const
	use the supplied arguments to make a schedulable and then insert it to be run More...

template<class Arg0 , class... ArgN>
auto	schedule (clock_type::time_point when, Arg0 &&a0, ArgN &&...an) const -> typename std::enable_if< (detail::is_action_function< Arg0 >::value\|\| is_subscription< Arg0 >::value)&& !is_schedulable< Arg0 >::value >::type
	use the supplied arguments to make a schedulable and then insert it to be run More...

template<class... ArgN>
void	schedule_rebind (clock_type::time_point when, const schedulable &scbl, ArgN &&...an) const
	use the supplied arguments to make a schedulable and then insert it to be run More...

template<class Arg0 , class... ArgN>
auto	schedule_periodically (clock_type::time_point initial, clock_type::duration period, Arg0 &&a0, ArgN &&...an) const -> typename std::enable_if< (detail::is_action_function< Arg0 >::value\|\| is_subscription< Arg0 >::value)&& !is_schedulable< Arg0 >::value >::type
	use the supplied arguments to make a schedulable and then insert it to be run More...

template<class... ArgN>
void	schedule_periodically_rebind (clock_type::time_point initial, clock_type::duration period, const schedulable &scbl, ArgN &&...an) const
	use the supplied arguments to make a schedulable and then insert it to be run More...

Additional Inherited Members
Public Types inherited from rxcpp::schedulers::worker
typedef scheduler_base::clock_type	clock_type

typedef composite_subscription::weak_subscription	weak_subscription

Public Types inherited from rxcpp::schedulers::worker_base
typedef tag_worker	worker_tag

Public Types inherited from rxcpp::subscription_base
typedef tag_subscription	subscription_tag

Constructor & Destructor Documentation

rxcpp::schedulers::test::test_worker::~test_worker ( )

inline

rxcpp::schedulers::test::test_worker::test_worker	(	composite_subscription	cs,
		std::shared_ptr< detail::test_type::test_type_worker >	t
	)

inlineexplicit

Member Function Documentation

void rxcpp::schedulers::test::test_worker::advance_by ( long time ) const

inline

void rxcpp::schedulers::test::test_worker::advance_to ( long time ) const

inline

long rxcpp::schedulers::test::test_worker::clock ( ) const

inline

bool rxcpp::schedulers::test::test_worker::is_enabled ( ) const

inline

template<class T >

subscriber<T, rxt::testable_observer<T> > rxcpp::schedulers::test::test_worker::make_subscriber ( ) const

inline

void rxcpp::schedulers::test::test_worker::schedule_absolute	(	long	when,
		const schedulable &	a
	)		const

inline

template<class Arg0 , class... ArgN>

auto rxcpp::schedulers::test::test_worker::schedule_absolute	(	long	when,
		Arg0 &&	a0,
		ArgN &&...	an
	)		const -> typename std::enable_if< (detail::is_action_function<Arg0>::value \|\| is_subscription<Arg0>::value) && !is_schedulable<Arg0>::value>::type

inline

void rxcpp::schedulers::test::test_worker::schedule_relative	(	long	when,
		const schedulable &	a
	)		const

inline

template<class Arg0 , class... ArgN>

auto rxcpp::schedulers::test::test_worker::schedule_relative	(	long	when,
		Arg0 &&	a0,
		ArgN &&...	an
	)		const -> typename std::enable_if< (detail::is_action_function<Arg0>::value \|\| is_subscription<Arg0>::value) && !is_schedulable<Arg0>::value>::type

inline

void rxcpp::schedulers::test::test_worker::sleep ( long time ) const

inline

template<class T , class F >

auto rxcpp::schedulers::test::test_worker::start	(	F	createSource,
		long	created,
		long	subscribed,
		long	unsubscribed
	)		const -> subscriber<T, rxt::testable_observer<T>>

inline

template<class T , class F >

auto rxcpp::schedulers::test::test_worker::start	(	F &&	createSource,
		long	unsubscribed
	)		const -> subscriber<T, rxt::testable_observer<T>>

inline

template<class T , class F >

auto rxcpp::schedulers::test::test_worker::start ( F && createSource ) const -> subscriber<T, rxt::testable_observer<T>>

inline

template<class F >

auto rxcpp::schedulers::test::test_worker::start	(	F	createSource,
		long	created,
		long	subscribed,
		long	unsubscribed
	)		const -> typename std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type

inline

template<class F >

auto rxcpp::schedulers::test::test_worker::start	(	F	createSource,
		long	unsubscribed
	)		const -> typename std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type

inline

template<class F >

auto rxcpp::schedulers::test::test_worker::start ( F createSource ) const -> typename std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type

inline

void rxcpp::schedulers::test::test_worker::start ( ) const

inline

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

/home/travis/build/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/rx-test.hpp

Classes

Public Member Functions

Additional Inherited Members

Constructor & Destructor Documentation

Member Function Documentation