Channel is a shareable reference to a writing endpoint of an isolate.
type of the events propagated by this channel
Used for building channel objects.
A pair of a channel and its event stream.
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 isolate died due to an exception.
the exception that the isolate threw
Thrown when an error in reactor execution occurs.
A system used to create, track and identify reactors.
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
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 isolates.
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 isolate was preempted by the scheduler.
Denotes that the isolate was scheduled for execution by the scheduler.
Denotes start of an isolate.
Contains factory methods for creating reactor systems.
Denotes the termination of an isolate.
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.