Micronaut core async subscribers.
ClassDescriptionInterface that exposes a callback to indicate when an operation has been completed.A
Subscriberthat tracks completion state using a
AtomicBoolean.Emitter<T>Base interface for classes that emit data.A
Subscriberdesigned to be used by a single thread that buffers incoming data for the purposes of managing back pressure.Back pressure state.A subscriber that is aware of the target type.