#
cp.rx.Observer
Observers are simple objects that receive values from Observables.
#
API Overview
Functions - API calls offered directly by the extension
is
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
onCompleted onError onNext
#
API Documentation
#
Functions
#
is
#
Constructors
#
create
#
Methods
#
onCompleted
#
onError
#
onNext
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.
Observables push values to Observers.
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
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 token passed to test functions to allow them to indicate if a test run will complete asynchronously.