#
cp.rx.Reference
A handle representing the link between an Observer and an Observable, as well as any work required to clean up after the Observable completes or the Observer cancels.
#
API Overview
Constructors - API calls which return an object, typically one that offers API methods
create
Methods - API calls which can only be made on an object returned by a constructor
cancel
#
API Documentation
#
Constructors
#
create
#
Methods
#
cancel
See also
Module
Reactive Extensions for Lua.
AsyncSubjects are subjects that produce either no values or a single value. If multiple values are produced via onNext, only the last one is used. If
A Subject that tracks its current value. Provides an accessor to retrieve the most recent pushed value, and all subscribers immediately receive the
Manages Observables using coroutines and a virtual clock that must be updated manually.
Schedules Observables by running all operations immediately.
Observables push values to Observers.
A Subject that provides new Observers with some or all of the most recently produced values upon reference.
Subjects function both as an Observer and as an Observable. Subjects inherit all Observable functions, including subscribe. Values can also be pushed
A scheduler that uses the hs.timer library to schedule events on an event loop.