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

Subject that replays the latest value to every new subscriber. setValue()/onNext() update the stored value and push it to observers. 更多...

#include <Rx.h>

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

Public 成员函数
	BehaviorSubject (T initial)
	Creates a subject with an initial (replayed) value.
Subscription	subscribe (Observer< T > obs) override
	Replays the latest value, then subscribes the observer.
T	getValue () const
	Current stored value.
void	setValue (T v)
	Stores a new value and pushes it to observers.
void	onNext (T v)
	Alias of setValue().
void	onError (const std::string &e)
	Stops replay and delivers a terminal error.
void	onCompleted ()
	Stops replay and delivers a terminal completion.
bool	hasObservers () const
	True while at least one live observer is registered.
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::BehaviorSubject< T >

Subject that replays the latest value to every new subscriber. setValue()/onNext() update the stored value and push it to observers.

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

构造及析构函数说明

BehaviorSubject()

template<typename T >

eve::rx::BehaviorSubject< T >::BehaviorSubject ( T  initial )

inlineexplicit

Creates a subject with an initial (replayed) value.

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

成员函数说明

getValue()

template<typename T >

T eve::rx::BehaviorSubject< T >::getValue ( ) const

inline

Current stored value.

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

hasObservers()

template<typename T >

bool eve::rx::BehaviorSubject< T >::hasObservers ( ) const

inline

True while at least one live observer is registered.

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

onCompleted()

template<typename T >

void eve::rx::BehaviorSubject< T >::onCompleted ( )

inline

Stops replay and delivers a terminal completion.

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

onError()

template<typename T >

void eve::rx::BehaviorSubject< T >::onError ( const std::string &  e )

inline

Stops replay and delivers a terminal error.

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

onNext()

template<typename T >

void eve::rx::BehaviorSubject< T >::onNext ( T  v )

inline

Alias of setValue().

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

引用了 eve::rx::BehaviorSubject< T >::setValue() , 以及 v.

setValue()

template<typename T >

void eve::rx::BehaviorSubject< T >::setValue ( T  v )

inline

Stores a new value and pushes it to observers.

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

引用了 v.

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

subscribe()

template<typename T >

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

inlineoverridevirtual

Replays the latest value, then subscribes the observer.

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

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

引用了 eve::rx::Observer< T >::next().

---

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

• src/modules/rx/Rx.h