载入中...
搜索中...
未找到
eve::rx 命名空间参考

class  AnonymousObservable
 Internal: observable built directly from a subscribe function. 更多...
 
class  BehaviorSubject
 Subject that replays the latest value to every new subscriber. setValue()/onNext() update the stored value and push it to observers. 更多...
 
class  Observable
 Push-based stream source. Operators return a new (caller-owned) Observable; subscribe() returns a Subscription used to cancel. 更多...
 
class  Observer
 Callback bundle pushed to a subscriber. Once error() or completed() fires the observer is stopped and later notifications are ignored. 更多...
 
class  ReactiveProperty
 Observable value backed by a BehaviorSubject. get() returns the current value; set() stores and pushes it to subscribers. 更多...
 
class  ReplaySubject
 Subject that buffers up to capacity values (0 = unlimited) and replays the buffer to every new subscriber. 更多...
 
class  Rx
 
class  Subject
 Multicast push-based stream: both an Observable and a push source. Thread-safe: onNext/onError/onCompleted/subscribe are mutex-protected. 更多...
 
class  Subscription
 RAII-style dispose handle for an active stream subscription. Disposing unsubscribes from the source; move-only. 更多...
 
class  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. 更多...
 

类型定义

using SubjectV = Subject< Value >
 
using BehaviorSubjectV = BehaviorSubject< Value >
 
using ReplaySubjectV = ReplaySubject< Value >
 
using ObservableV = Observable< Value >
 
using ReactivePropertyV = ReactiveProperty< Value >
 

函数

 Module_IMPL (Rx, new Rx())
 

类型定义说明

◆ BehaviorSubjectV

在文件 Rx.cpp146 行定义.

◆ ObservableV

在文件 Rx.cpp148 行定义.

◆ ReactivePropertyV

在文件 Rx.cpp149 行定义.

◆ ReplaySubjectV

在文件 Rx.cpp147 行定义.

◆ SubjectV

using eve::rx::SubjectV = typedef Subject<Value>

在文件 Rx.cpp145 行定义.

函数说明

◆ Module_IMPL()

eve::rx::Module_IMPL ( Rx  ,
new   Rx() 
)