Package io.helidon.common.reactive

Common reactive library for Helidon projects.

See Also:

Flow, ReactiveStreamsAdapter, OutputStreamPublisher, SubmissionPublisher

Interface Summary

Interface	Description
Collector<T,U>	A collector accumulates the items provided when Collector.collect(java.lang.Object) is invoked and makes them available in a single container object with Collector.value().
Flow.Processor<T,R>	A component that acts as both a Subscriber and Publisher.
Flow.Publisher<T>	A producer of items (and related control messages) received by Subscribers.
Flow.Subscriber<T>	A receiver of messages.
Flow.Subscription	Message control linking a Flow.Publisher and Flow.Subscriber.
Multi<T>	Multiple items publisher facility.
RetrySchema	Defines delay for next read/poll operation in a polling publisher.
Single<T>	Single item publisher utility.
Subscribable<T>	Decorated publisher that allows subscribing to individual events with java functions.

Class Summary

Class	Description
Flow	Interrelated interfaces and static methods for establishing flow-controlled components in which Publishers produce items consumed by one or more Subscribers, each managed by a Subscription.
OriginThreadPublisher<T,U>	The OriginThreadPublisher's nature is to always run Flow.Subscriber.onNext(Object) on the very same thread as OriginThreadPublisher.submit(Object).
OutputStreamPublisher	Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.
ReactiveStreamsAdapter	Deprecated. This class will be removed in the next major release.
RequestedCounter	Requested event counter.
SingleSubscriberHolder<T>	A subscriber container that accepts only a single, one-time subscriber registration.
SubmissionPublisher<T>	Deprecated. This class will be removed in the next major release.
UnboundedSemaphore	The UnboundedSemaphore is designed to fit Reactive Streams use-case; that is to be able to allow an unbounded number of acquires once a cumulative release count reaches Long.MAX_VALUE.