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

Callback bundle pushed to a subscriber. Once error() or completed() fires the observer is stopped and later notifications are ignored. 更多...

#include <Rx.h>

Public 类型
using	NextFn = std::function< void(const T &)>
using	ErrorFn = std::function< void(const std::string &)>
using	CompletedFn = std::function< void()>

Public 成员函数
bool	isStopped () const
	True after error()/completed() (or setStopped()).
void	setStopped () const
	Manually marks the observer stopped (used by operators).
void	next (const T &v) const
	Delivers a value unless stopped.
void	error (const std::string &e) const
	Delivers a terminal error and stops.
void	completed () const
	Delivers a terminal completion and stops.

Public 属性
NextFn	onNext
	Value callback.
ErrorFn	onError
	Error callback (terminal).
CompletedFn	onCompleted
	Completion callback (terminal).

详细描述

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

Callback bundle pushed to a subscriber. Once error() or completed() fires the observer is stopped and later notifications are ignored.

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

成员类型定义说明

CompletedFn

template<typename T >

using eve::rx::Observer< T >::CompletedFn = std::function<void()>

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

ErrorFn

template<typename T >

using eve::rx::Observer< T >::ErrorFn = std::function<void(const std::string&)>

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

NextFn

template<typename T >

using eve::rx::Observer< T >::NextFn = std::function<void(const T&)>

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

成员函数说明

completed()

template<typename T >

void eve::rx::Observer< T >::completed ( ) const

inline

Delivers a terminal completion and stops.

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

引用了 eve::rx::Observer< T >::onCompleted.

被这些函数引用 eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Subject< T >::onCompleted(), eve::rx::Observable< T >::skip(), eve::rx::Subject< T >::subscribe(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

error()

template<typename T >

void eve::rx::Observer< T >::error ( const std::string &  e ) const

inline

Delivers a terminal error and stops.

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

引用了 eve::rx::Observer< T >::onError.

被这些函数引用 eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Subject< T >::onError(), eve::rx::Observable< T >::skip(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

isStopped()

template<typename T >

bool eve::rx::Observer< T >::isStopped ( ) const

inline

True after error()/completed() (or setStopped()).

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

被这些函数引用 eve::rx::ReplaySubject< T >::subscribe().

next()

template<typename T >

void eve::rx::Observer< T >::next ( const T &  v ) const

inline

Delivers a value unless stopped.

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

引用了 eve::rx::Observer< T >::onNext , 以及 v.

被这些函数引用 eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Subject< T >::onNext(), eve::rx::Observable< T >::skip(), eve::rx::BehaviorSubject< T >::subscribe(), eve::rx::ReplaySubject< T >::subscribe(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

setStopped()

template<typename T >

void eve::rx::Observer< T >::setStopped ( ) const

inline

Manually marks the observer stopped (used by operators).

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

类成员变量说明

onCompleted

template<typename T >

CompletedFn eve::rx::Observer< T >::onCompleted

Completion callback (terminal).

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

被这些函数引用 eve::rx::Observer< T >::completed(), eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Observable< T >::skip(), eve::rx::Observable< T >::subscribe(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

onError

template<typename T >

ErrorFn eve::rx::Observer< T >::onError

Error callback (terminal).

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

被这些函数引用 eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observer< T >::error(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Observable< T >::skip(), eve::rx::Observable< T >::subscribe(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

onNext

template<typename T >

NextFn eve::rx::Observer< T >::onNext

Value callback.

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

被这些函数引用 eve::rx::Observable< T >::distinctUntilChanged(), eve::rx::Observable< T >::filter(), eve::rx::Observable< T >::first(), eve::rx::Observable< T >::map(), eve::rx::Observer< T >::next(), eve::rx::Observable< T >::skip(), eve::rx::Observable< T >::subscribe(), eve::rx::Observable< T >::subscribe(), eve::rx::Observable< T >::take() , 以及 eve::rx::Observable< T >::takeUntil().

---

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

• src/modules/rx/Rx.h