Package io.micronaut.core.async.processor

Micronaut core async processing.

See: Description

Class Summary

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.

Package io.micronaut.core.async.processor Description

Micronaut core async processing.

Since:

1.0

Author:

graemerocher