Rx.h 文件参考

#include <functional>
#include <memory>
#include <mutex>
#include <string>
#include <vector>
#include "common/Exception.h"

浏览源代码.

类
class	eve::rx::Value
	Runtime variant used by the script-facing (Squirrel) streams. The C++ core is templated (Observer<T>/Observable<T>/Subject<T>); the module binds a Value-typed specialization so scripts can push nil/int/float/bool/ string/ptr. 更多...
class	eve::rx::Subscription
	RAII-style dispose handle for an active stream subscription. Disposing unsubscribes from the source; move-only. 更多...
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. 更多...
class	eve::rx::Observable< T >
	Push-based stream source. Operators return a new (caller-owned) Observable; subscribe() returns a Subscription used to cancel. 更多...
class	eve::rx::AnonymousObservable< T >
	Internal: observable built directly from a subscribe function. 更多...
class	eve::rx::Subject< T >
	Multicast push-based stream: both an Observable and a push source. Thread-safe: onNext/onError/onCompleted/subscribe are mutex-protected. 更多...
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. 更多...
class	eve::rx::ReplaySubject< T >
	Subject that buffers up to capacity values (0 = unlimited) and replays the buffer to every new subscriber. 更多...
class	eve::rx::ReactiveProperty< T >
	Observable value backed by a BehaviorSubject. get() returns the current value; set() stores and pushes it to subscribers. 更多...

命名空间
namespace	eve
namespace	eve::rx