eve::rx::AnonymousObservable< T > 模板类 参考

Internal: observable built directly from a subscribe function. 更多...

#include <Rx.h>

类 eve::rx::AnonymousObservable< T > 继承关系图:

Public 成员函数
	AnonymousObservable (std::function< Subscription(Observer< T >)> fn)
Subscription	subscribe (Observer< T > obs) override
	Subscribes with a full observer; returns a cancel handle.
Public 成员函数 继承自 eve::rx::Observable< T >
virtual	~Observable ()=default
Subscription	subscribe (typename Observer< T >::NextFn next)
	Subscribes with a value callback only.
Subscription	subscribe (typename Observer< T >::NextFn next, typename Observer< T >::ErrorFn error, typename Observer< T >::CompletedFn completed)
	Subscribes with value/error/completed callbacks.
Observable< T > *	filter (std::function< bool(const T &)> pred)
	Passes values through only when pred(v) is true.
template<typename R >
Observable< R > *	map (std::function< R(const T &)> fn)
	Transforms each value with fn.
Observable< T > *	take (int n)
	Emits at most the first n values, then completes.
Observable< T > *	skip (int n)
	Drops the first n values.
Observable< T > *	first ()
	Emits only the first value, then completes.
Observable< T > *	takeUntil (Observable< T > *other)
	Stops the stream when other emits or completes.
Observable< T > *	distinctUntilChanged ()
	Suppresses consecutive duplicate values (uses operator==).

详细描述

template<typename T>
class eve::rx::AnonymousObservable< T >

Internal: observable built directly from a subscribe function.

在文件 Rx.h 第 223 行定义.

构造及析构函数说明

AnonymousObservable()

template<typename T >

eve::rx::AnonymousObservable< T >::AnonymousObservable ( std::function< Subscription(Observer< T >)>  fn )

inlineexplicit

在文件 Rx.h 第 225 行定义.

成员函数说明

subscribe()

template<typename T >

Subscription eve::rx::AnonymousObservable< T >::subscribe ( Observer< T >  obs )

inlineoverridevirtual

Subscribes with a full observer; returns a cancel handle.

实现了 eve::rx::Observable< T >.

在文件 Rx.h 第 227 行定义.

---

该类的文档由以下文件生成:

• src/modules/rx/Rx.h