Package io.micronaut.core.async.subscriber

@NullMarked package io.micronaut.core.async.subscriber

Micronaut core async subscribers.

Since:

1.0

Author:

graemerocher

Related Packages

Package	Description
io.micronaut.core.async	Supplier helper methods.
io.micronaut.core.async.annotation
io.micronaut.core.async.converters	Converters for reactive types.
io.micronaut.core.async.processor	Micronaut core async processing.
io.micronaut.core.async.propagation	Propagation support for reactive types.
io.micronaut.core.async.publisher	Micronaut core async publishing.

Class	Description
Completable	Interface that exposes a callback to indicate when an operation has been completed.
CompletionAwareSubscriber<T>	A Subscriber that tracks completion state using a AtomicBoolean.
Emitter<T>	Base interface for classes that emit data.
LazySendingSubscriber<T>	This class waits for the first item of a publisher before completing an ExecutionFlow with a publisher containing the same items.
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.