Channel is a shareable reference to a writing endpoint of a reactor.
type of the events propagated by this channel
Used for building channel objects.
A pair of a channel and its event stream.
Debugger interface for the reactor system.
The default handler prints the exception to the standard error stream.
Class that describes error handlers that report uncaught reactor-level exceptions.
A queue that buffers events that arrive on the corresponding channel.
A basic event stream.
type of the events in this event stream
An event stream that can be either completed, or unreacted at most once.
type of the value in the
Any object that contains a unique id within some scope.
An object that can act upon an event or be signalled that there will be no more events.
type of events the observer responds to
A prototype for instantiating a reactor that takes specific parameters.
type of the reactor
An encapsulation of a set of event streams and channels.
The reactive cell abstraction represents a mutable memory location whose changes may produce events.
the type of the values it stores
A reactor is a basic unit of concurrency.
the type of events, which
this reactor produces
Denotes that the reactor died due to an exception.
the exception that the reactor threw
Thrown when an error in reactor execution occurs.
A system used to create, track and identify reactors.
Service that tracks different transports for remote communication.
An object that schedules reactors for execution.
A special type of an event stream that caches the last emitted event.
the type of the events in this signal
Silent handler ignores exceptions.
Evidence value for specialized type parameters.
A subscription to a certain kind of event, event processing or computation.
System events are a special kind of internal events that can be observed by reactors.
Thrown when an exception is propagated to an event handler, such as
Default channel implementations.
Contains default event queue implementations.
Events implementations and factory methods.
Matches lethal throwables.
Matches non-lethal throwables.
Denotes that the reactor was preempted by the scheduler.
Denotes that the reactor was scheduled for execution by the scheduler.
Denotes start of a reactor.
Contains factory methods for creating reactor systems.
Denotes the termination of a reactor.
Companion object for creating standard reactor schedulers.
Default subscription implementations.
Partial function ignores non-lethal throwables.
Determines if the throwable is lethal, i.e.
Determines if the throwable is not lethal.