All Classes

Class	Description
AsyncSingleResultPublisher<T>	A Publisher that uses an ExecutorService to emit a single result.
Completable	Interface that exposes a callback to indicate when an operation has been completed.
CompletableFuturePublisher<T>	Adapts a CompletableFuture to a Publisher.
CompletionAwareSubscriber<T>	A Subscriber that tracks completion state using a AtomicBoolean.
Emitter<T>	Base interface for classes that emit data.
Publishers	Utilities for working with raw Publisher instances.
Publishers.JustPublisher<T>	A publisher for a value.
Publishers.MapOrSupplyEmpty<T,R>	Maps the next result or supplies an empty result.
Publishers.MicronautPublisher<T>	Marker interface for any micronaut produced publishers.
PublishersOptimizations	Static optimizations for the class.
ReactiveStreamsTypeInformationProvider	Implementation of TypeInformationProvider for reactive streams.
SingleResult	Annotation that can be used to describe that an API emits a single result even if the return type is a Publisher.
SingleSubscriberProcessor<T,R>	A Processor that only allows a single Subscriber
SingleSubscriberPublisher<T>	A Publisher that only allows a single Subscriber.
SingleThreadedBufferingProcessor<R,T>	A Reactive streams Processor designed to be used within a single thread and manage back pressure state.
SingleThreadedBufferingSubscriber<T>	A Subscriber designed to be used by a single thread that buffers incoming data for the purposes of managing back pressure.
SingleThreadedBufferingSubscriber.BackPressureState	Back pressure state.
TypedSubscriber<T>	A subscriber that is aware of the target type.