Package io.micronaut.core.async.processor

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

Micronaut core async processing.

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.propagation	Propagation support for reactive types.
io.micronaut.core.async.publisher	Micronaut core async publishing.
io.micronaut.core.async.subscriber	Micronaut core async subscribers.

Classes

Class	Description
SingleSubscriberProcessor<T,R>	A Processor 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.