A reactive emitter that can be used with the
The default implementation of a reactive value.
A reactive value that can programatically emit events.
A base trait for reactives that never emit events.
The proxy reactive that emits events of its underlying reactive.
Unsubscribes by calling
unsubscribe on the underlying subscription.
A subscription to a certain kind of event, event processing or computation in general.
Unsubscribing will call
unsubscribe on all the
the child subscriptions
the composite subscription
A reactive that never emits events.
type of events in this reactive
Contains factory methods for subscription.
Defines a new passive reactive that emits several events to any new subscriber.
type of the events to emit
events to emit
a reactive that emits the specified events
Creates a new reactive that invokes the function
f on any
Reactor that subscribes to it.
type of the events in this passive reactive
function to execute on any newly subscribed reactor
the passive reactive defined by
You should never use this method to bind reactors to bind reactors to custom callbacks in 3rd party APIs. Those callbacks may execute on another thread, and that is *unsafe*.
Defines a new passive reactive that emits a single event to any new subscriber.
type of the event to emit
event to emit
a reactive that emits a single event