@NonNullApi

Package reactor.core.publisher

Provide for Flux, Mono composition API and Processor implementations

See: Description

Interface Summary

Interface	Description
FluxSink<T>	Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.
MonoSink<T>	Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).
Signal<T>	A domain representation of a Reactive Stream signal.
SynchronousSink<T>	Interface to produce synchronously "one signal" to an underlying Subscriber.

Class Summary

Class	Description
BaseSubscriber<T>	A simple base class for a Subscriber implementation that lets the user perform a BaseSubscriber.request(long) and BaseSubscriber.cancel() on it directly.
ConnectableFlux<T>	The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
DirectProcessor<T>	Dispatches onNext, onError and onComplete signals to zero-to-many Subscribers.
EmitterProcessor<T>	An implementation of a message-passing Processor implementing publish-subscribe with synchronous (thread-stealing and happen-before interactions) drain loops.
Flux<T>	A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
FluxOperator<I,O>	A decorating Flux Publisher that exposes Flux API over an arbitrary Publisher Useful to create operators which return a Flux.
FluxProcessor<IN,OUT>	A base processor that exposes Flux API for Processor.
GroupedFlux<K,V>	Represents a sequence of events which has an associated key.
Hooks	A set of overridable lifecycle hooks that can be used for cross-cutting added behavior on Flux/Mono operators.
Mono<T>	A Reactive Streams Publisher with basic rx operators that completes successfully by emitting an element, or with an error.
MonoOperator<I,O>	A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.
MonoProcessor<O>	A MonoProcessor is a Mono extension that implements stateful semantics.
Operators	An helper to support "Operator" writing, handle noop subscriptions, validate request size and to cap concurrent additive operations to Long.MAX_VALUE, which is generic to Subscription.request(long) handling.
Operators.DeferredSubscription	Base class for Subscribers that will receive their Subscriptions at any time, yet they might also need to be cancelled or requested at any time.
Operators.MonoSubscriber<I,O>	A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors resulting from concurrent request or cancel and onXXX signals.
ParallelFlux<T>	A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').
ReplayProcessor<T>	Replays all or the last N items to Subscribers.
TopicProcessor<E>	An implementation of a RingBuffer backed message-passing Processor implementing publish-subscribe with async event loops.
TopicProcessor.Builder<T>	TopicProcessor builder that can be used to create new processors.
UnicastProcessor<T>	A Processor implementation that takes a custom queue and allows only a single subscriber.
WorkQueueProcessor<E>	An implementation of a RingBuffer backed message-passing Processor implementing work-queue distribution with async event loops.
WorkQueueProcessor.Builder<T>	WorkQueueProcessor builder that can be used to create new processors.

Enum Summary

Enum	Description
BufferOverflowStrategy	Strategies to deal with overflow of a buffer during backpressure buffering.
FluxSink.OverflowStrategy	Enumeration for backpressure handling.
SignalType	Reactive Stream signal types

Package reactor.core.publisher Description

Provide for Flux, Mono composition API and Processor implementations

Flux

A typed N-elements or zero sequence Publisher with core reactive extensions.

Mono

A typed one-element at most sequence Publisher with core reactive extensions.

Processors

The following Processor extending FluxProcessor are available:

• A synchronous/non-opinionated pub-sub replaying capable event emitter : EmitterProcessor, ReplayProcessor, UnicastProcessor and DirectProcessor
• A dedicated parallel pub-sub event buffering broadcaster : TopicProcessor
• A dedicated parallel work queue distribution for slow consumers : WorkQueueProcessor
• FluxProcessor itself offers factories to build arbitrary Processor

Author:

Stephane Maldini