Package io.micronaut.core.async.subscriber

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
io.micronaut.core.async.processor	Micronaut core async processing.
io.micronaut.core.async.propagation
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.
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.