@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.
Sinks.EmitFailureHandler	A handler supporting the emit API (eg.
Sinks.Empty<T>	A base interface for standalone Sinks with complete-or-fail semantics.
Sinks.Many<T>	A base interface for standalone Sinks with Flux semantics.
Sinks.ManySpec	Provides Sinks.Many specs for sinks which can emit multiple elements
Sinks.MulticastReplaySpec	Provides multicast with history/replay capacity : 1 sink, N Subscriber
Sinks.MulticastSpec	Provides multicast : 1 sink, N Subscriber
Sinks.One<T>	A base interface for standalone Sinks with Mono semantics.
Sinks.RootSpec	Provides a choice of Sinks.One/Sinks.Empty factories and further specs for Sinks.Many.
Sinks.UnicastSpec	Provides unicast: 1 sink, 1 Subscriber
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>	Deprecated To be removed in 3.5, prefer clear cut usage of Sinks.
EmitterProcessor<T>	Deprecated To be removed in 3.5.
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.
FluxProcessor<IN,OUT>	Deprecated Processors will be removed in 3.5.
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>	Deprecated Processors will be removed in 3.5.
Operators	A 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>	Deprecated To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
SinkOneSerialized<T>
Sinks	Sinks are constructs through which Reactive Streams signals can be programmatically pushed, with Flux or Mono semantics.
UnicastProcessor<T>	Deprecated to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

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
Sinks.EmitResult	Represents the immediate result of an emit attempt (eg.

Exception Summary

Exception	Description
Sinks.EmissionException	An exception representing a failed Sinks.EmitResult.

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
• FluxProcessor itself offers factories to build arbitrary Processor

Author:

Stephane Maldini