Top Description Interfaces Classes
[default module]

Package reactor.core

Annotations
@NonNullApi
Imports
reactor.util.annotation.NonNullApi
Core components of the framework supporting extensions to the Reactive Stream programming model.

Interface Summary

Modifier and TypeInterface and Description
public interface
CorePublisher<
the CoreSubscriber data type
T>

A CoreSubscriber aware publisher.

public interface
CoreSubscriber<
the Subscriber data type
T>

A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original org.reactivestreams.Subscriber from Reactive Streams.

public interface
Disposable

Indicates that a task or resource can be cancelled/disposed.

public interface
Fuseable

A micro API for stream fusion, in particular marks producers that support a QueueSubscription.

public interface
Scannable

A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.

Class Summary

Modifier and TypeClass and Description
public class
Disposables

A support class that offers factory methods for implementations of the specialized Disposable sub-interfaces (Disposable.Composite, Disposable.Swap).

public abstract class
Exceptions

Global Reactor Core Exception handling and utils to operate on.