Uses of Package
reactor.core.publisher

Packages that use reactor.core.publisher

Package	Description
reactor.adapter	Adapt Publisher to Java 9+ Flow.Publisher.
reactor.core.observability
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.core.scheduler	Scheduler contract and static registry and factory methods in Schedulers.
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.test.publisher	Components supporting the creation of test-oriented Publishers.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.
reactor.util.retry

Classes in reactor.core.publisher used by reactor.adapter

Class and Description
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).

Classes in reactor.core.publisher used by reactor.core.observability

Class and Description
SignalType Reactive Stream signal types

Classes in reactor.core.publisher used by reactor.core.publisher

Class and Description
BufferOverflowStrategy Strategies to deal with overflow of a buffer during backpressure buffering.
ConnectableFlux The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
DirectProcessor Deprecated. To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
EmitterProcessor Deprecated. To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
FluxProcessor Deprecated. Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
FluxSink Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.
FluxSink.OverflowStrategy Enumeration for backpressure handling.
GroupedFlux Represents a sequence of events which has an associated key.
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).
MonoProcessor Deprecated. Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
MonoSink Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).
ParallelFlux A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').
ReplayProcessor Deprecated. To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
Signal A domain representation of a Reactive Stream signal.
SignalType Reactive Stream signal types
Sinks.EmitFailureHandler A handler supporting the emit API (eg.
Sinks.EmitResult Represents the immediate result of an emit attempt (eg.
Sinks.Empty A base interface for standalone Sinks with complete-or-fail semantics.
Sinks.Many A base interface for standalone Sinks with Flux semantics.
Sinks.ManySpec Provides Sinks.Many specs for sinks which can emit multiple elements
Sinks.ManyWithUpstream A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.
Sinks.ManyWithUpstreamUnsafeSpec Instead of unsafe flavors of Sinks.Many, this spec provides Sinks.ManyWithUpstream implementations.
Sinks.MulticastReplaySpec Provides multicast with history/replay capacity : 1 sink, N Subscriber
Sinks.MulticastSpec Provides multicast : 1 sink, N Subscriber
Sinks.One 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 Interface to produce synchronously "one signal" to an underlying Subscriber.
Timed
UnicastProcessor Deprecated. to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

Classes in reactor.core.publisher used by reactor.core.scheduler

Class and Description
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).

Classes in reactor.core.publisher used by reactor.test

Class and Description
Signal A domain representation of a Reactive Stream signal.

Classes in reactor.core.publisher used by reactor.test.publisher

Class and Description
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).

Classes in reactor.core.publisher used by reactor.test.subscriber

Class and Description
Signal A domain representation of a Reactive Stream signal.

Classes in reactor.core.publisher used by reactor.util.retry

Class and Description
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).