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

Subject that buffers up to capacity values (0 = unlimited) and replays the buffer to every new subscriber. 更多...

#include <Rx.h>

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

Public 成员函数
	ReplaySubject (int capacity=0)
	Creates a replaying subject with the given buffer capacity.
Subscription	subscribe (Observer< T > obs) override
	Replays buffered values, then subscribes the observer.
void	onNext (T v)
	Buffers and pushes a new value to observers.
void	onError (const std::string &e)
	Delivers a terminal error to observers.
void	onCompleted ()
	Delivers a terminal completion to observers.
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::ReplaySubject< T >

Subject that buffers up to capacity values (0 = unlimited) and replays the buffer to every new subscriber.

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

构造及析构函数说明

ReplaySubject()

template<typename T >

eve::rx::ReplaySubject< T >::ReplaySubject ( int  capacity = 0 )

inlineexplicit

Creates a replaying subject with the given buffer capacity.

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

成员函数说明

hasObservers()

template<typename T >

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

inline

True while at least one live observer is registered.

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

onCompleted()

template<typename T >

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

inline

Delivers a terminal completion to observers.

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

onError()

template<typename T >

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

inline

Delivers a terminal error to observers.

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

onNext()

template<typename T >

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

inline

Buffers and pushes a new value to observers.

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

引用了 v.

subscribe()

template<typename T >

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

inlineoverridevirtual

Replays buffered values, then subscribes the observer.

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

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

引用了 eve::rx::Observer< T >::isStopped(), eve::rx::Observer< T >::next() , 以及 v.

---

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

• src/modules/rx/Rx.h