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

Push-based stream source. Operators return a new (caller-owned) Observable; subscribe() returns a Subscription used to cancel. 更多...

#include <Rx.h>

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

Public 成员函数
virtual	~Observable ()=default
virtual Subscription	subscribe (Observer< T > obs)=0
	Subscribes with a full observer; returns a cancel handle.
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::Observable< T >

Push-based stream source. Operators return a new (caller-owned) Observable; subscribe() returns a Subscription used to cancel.

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

构造及析构函数说明

~Observable()

template<typename T >

virtual eve::rx::Observable< T >::~Observable ( )

virtualdefault

成员函数说明

distinctUntilChanged()

template<typename T >

Observable< T > * eve::rx::Observable< T >::distinctUntilChanged

(

)

Suppresses consecutive duplicate values (uses operator==).

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

filter()

template<typename T >

Observable< T > * eve::rx::Observable< T >::filter

(

std::function< bool(const T &)>

pred

)

Passes values through only when pred(v) is true.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

first()

template<typename T >

Observable< T > * eve::rx::Observable< T >::first

(

)

Emits only the first value, then completes.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

map()

template<typename T >

template<typename R >

Observable< R > * eve::rx::Observable< T >::map

(

std::function< R(const T &)>

fn

)

Transforms each value with fn.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), fn, eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

skip()

template<typename T >

Observable< T > * eve::rx::Observable< T >::skip

(

int

n

)

Drops the first n values.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), n, eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

subscribe() [1/3]

template<typename T >

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

pure virtual

Subscribes with a full observer; returns a cancel handle.

在 eve::rx::AnonymousObservable< T >, eve::rx::Subject< T >, eve::rx::BehaviorSubject< T > , 以及 eve::rx::ReplaySubject< T > 内被实现.

被这些函数引用 eve::rx::Observable< T >::subscribe(), eve::rx::Observable< T >::subscribe() , 以及 eve::rx::Observable< T >::takeUntil().

subscribe() [2/3]

template<typename T >

Subscription eve::rx::Observable< T >::subscribe ( typename Observer< T >::NextFn  next )

inline

Subscribes with a value callback only.

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

引用了 eve::rx::Observer< T >::onNext , 以及 eve::rx::Observable< T >::subscribe().

subscribe() [3/3]

template<typename T >

Subscription eve::rx::Observable< T >::subscribe ( typename Observer< T >::NextFn  next, typename Observer< T >::ErrorFn  error, typename Observer< T >::CompletedFn  completed  )

inline

Subscribes with value/error/completed callbacks.

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

引用了 error, eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 eve::rx::Observable< T >::subscribe().

take()

template<typename T >

Observable< T > * eve::rx::Observable< T >::take

(

int

n

)

Emits at most the first n values, then completes.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), n, eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext , 以及 v.

takeUntil()

template<typename T >

Observable< T > * eve::rx::Observable< T >::takeUntil

(

Observable< T > *

other

)

Stops the stream when other emits or completes.

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

引用了 eve::rx::Observer< T >::completed(), eve::rx::Observer< T >::error(), eve::rx::Observer< T >::next(), eve::rx::Observer< T >::onCompleted, eve::rx::Observer< T >::onError, eve::rx::Observer< T >::onNext, eve::rx::Observable< T >::subscribe() , 以及 v.

---

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

• src/modules/rx/Rx.h