Package io.micronaut.core.async.processor
Micronaut core async processing.
- Since:
- 1.0
-
Class Summary Class Description SingleSubscriberProcessor<T,R> AProcessorthat only allows a singleSubscriberSingleThreadedBufferingProcessor<R,T> A Reactive streamsProcessordesigned to be used within a single thread and manage back pressure state.