Package reactor.core

Core components of the Loggers framework supporting Reactive Stream programming model.

See: Description

Interface Summary

Interface	Description
Cancellation	Indicates that a task or resource can be cancelled/disposed.
Fuseable	A micro API for stream fusion, in particular marks producers that support a Fuseable.QueueSubscription.
Fuseable.ConditionalSubscriber<T>	A subscriber variant that can immediately tell if it consumed the value or not, avoiding the usual request(1) for dropped values.
Fuseable.QueueSubscription<T>	Contract queue-fusion based optimizations for supporting subscriptions.
Fuseable.ScalarCallable<T>	Marker interface indicating that the target can return a value or null immediately and thus a viable target for assembly-time optimizations.
Fuseable.SynchronousSubscription<T>	Base class for synchronous sources which have fixed size and can emit its items in a pull fashion, thus avoiding the request-accounting overhead in many cases.
Loopback	A component that is forking to a sub-flow given a delegate input and that is consuming from a given delegate output
MultiProducer	A component that will emit events to N downstreams.
MultiReceiver	A component that is linked to N upstreams producers.
Producer	A component that will emit events to a downstream.
Receiver	A component that is linked to a source producer.
Trackable	A lifecycle backed downstream

Class Summary

Class	Description
Exceptions	Global Reactor Core Exception handling and utils to operate on.

Package reactor.core Description

Core components of the Loggers framework supporting Reactive Stream programming model. Topology representation of reactive flows : upstream (s), downstream (s) and loopback flows.