Package io.micronaut.core.async.publisher

package io.micronaut.core.async.publisher

Micronaut core async publishing.

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.subscriber	Micronaut core async subscribers.

Class	Description
AsyncSingleResultPublisher<T>	A Publisher that uses an ExecutorService to emit a single result.
CompletableFuturePublisher<T>	Adapts a CompletableFuture to a Publisher.
DelayedSubscriber<T>	This is a Processor that does not change the stream, but allows the upstream Publisher and downstream Subscriber to be set independently in any order.
Publishers	Utilities for working with raw Publisher instances.
Publishers.JustPublisher<T>	A publisher for a value.
Publishers.JustThrowPublisher<T>	A publisher that throws an error.
Publishers.MapOrSupplyEmpty<T,R>	Maps the next result or supplies an empty result.
Publishers.MicronautPublisher<T>	Marker interface for any micronaut produced publishers.
PublishersOptimizations	Static optimizations for the class.
SingleSubscriberPublisher<T>	A Publisher that only allows a single Subscriber.