All Classes
-
All Classes Interface Summary Class Summary Enum Summary Annotation Types Summary Class Description AsyncSingleResultPublisher<T> APublisherthat uses anExecutorServiceto emit a single result.Completable Interface that exposes a callback to indicate when an operation has been completed.CompletableFuturePublisher<T> Adapts aCompletableFutureto aPublisher.CompletionAwareSubscriber<T> ASubscriberthat tracks completion state using aAtomicBoolean.Emitter<T> Base interface for classes that emit data.Publishers Utilities for working with rawPublisherinstances.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 theclass.ReactiveStreamsTypeInformationProvider Implementation ofTypeInformationProviderfor reactive streams.SingleResult Annotation that can be used to describe that an API emits a single result even if the return type is aPublisher.SingleSubscriberProcessor<T,R> AProcessorthat only allows a singleSubscriberSingleSubscriberPublisher<T> APublisherthat only allows a singleSubscriber.SingleThreadedBufferingProcessor<R,T> A Reactive streamsProcessordesigned to be used within a single thread and manage back pressure state.SingleThreadedBufferingSubscriber<T> ASubscriberdesigned 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.