Uses of Interface
org.bsc.async.AsyncGenerator

Packages that use AsyncGenerator

Package	Description
org.bsc.async
org.bsc.async.internal.reactive
org.bsc.async.v5

Uses of AsyncGenerator in org.bsc.async

Subinterfaces of AsyncGenerator in org.bsc.async

Modifier and Type	Interface	Description
static interface	AsyncGenerator.Cancellable<E>

Classes in org.bsc.async that implement AsyncGenerator

Modifier and Type	Class	Description
static class	AsyncGenerator.Base<E>	Abstract base class for AsyncGenerator implementations.
static class	AsyncGenerator.BaseCancellable<E>
static class	AsyncGenerator.WithEmbed<E>	An asynchronous generator decorator that allows to generators composition embedding other generators.
static class	AsyncGenerator.WithResult<E>	An asynchronous generator decorator that allows retrieving the result value of the asynchronous operation, if any.
static class	AsyncGeneratorQueue.Generator<E>	Deprecated, for removal: This API element is subject to removal in a future version. Inner class to generate asynchronous elements from the queue.

Methods in org.bsc.async that return AsyncGenerator

Modifier and Type	Method	Description
AsyncGenerator<E>	AsyncGenerator.WithResult.delegate()
static <E> AsyncGenerator<E>	AsyncGenerator.empty()	Returns an empty AsyncGenerator.
default <U> AsyncGenerator<U>	AsyncGenerator.flatMap(Function<E,CompletableFuture<U>> mapFunction)	Maps the elements of this generator to a new asynchronous generator, and flattens the resulting nested generators.
static <E> AsyncGenerator<E>	AsyncGenerator.from(Iterator<E> iterator)	Collects asynchronous elements from an iterator.
AsyncGenerator<E>	AsyncGenerator.Embed.generator()	Returns the value of the generator record component.
default <U> AsyncGenerator<U>	AsyncGenerator.map(Function<E,U> mapFunction)	Maps the elements of this generator to a new asynchronous generator.
static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>> AsyncGenerator<E>	AsyncGeneratorQueue.of(Q queue, Consumer<Q> consumer)	Deprecated, for removal: This API element is subject to removal in a future version. Creates an AsyncGenerator from the provided blocking queue and consumer.
static <E, Q extends BlockingQueue<AsyncGenerator.Data<E>>> AsyncGenerator<E>	AsyncGeneratorQueue.of(Q queue, Consumer<Q> consumer, Executor executor)	Deprecated, for removal: This API element is subject to removal in a future version. Creates an AsyncGenerator from the provided queue, executor, and consumer.

Methods in org.bsc.async with parameters of type AsyncGenerator

Modifier and Type	Method	Description
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.composeWith(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)
static Optional<Object>	AsyncGenerator.resultValue(AsyncGenerator<?> generator)
static <T> Flow.Publisher<T>	FlowGenerator.toPublisher(AsyncGenerator<T> generator)	Converts an AsyncGenerator into a Flow.Publisher.

Constructors in org.bsc.async with parameters of type AsyncGenerator

Modifier	Constructor	Description
	Embed(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)	Creates an instance of a Embed record class.
	WithEmbed(AsyncGenerator<E> delegate)
	WithEmbed(AsyncGenerator<E> delegate, AsyncGenerator.EmbedCompletionHandler onGeneratorDoneWithResult)
	WithResult(AsyncGenerator<E> delegate)

Uses of AsyncGenerator in org.bsc.async.internal.reactive

Classes in org.bsc.async.internal.reactive that implement AsyncGenerator

Modifier and Type	Class	Description
class	GeneratorSubscriber<T>	Represents a subscriber for generating asynchronous data streams.

Constructors in org.bsc.async.internal.reactive with parameters of type AsyncGenerator

Modifier	Constructor	Description
	GeneratorPublisher(AsyncGenerator<? extends T> delegate)	Constructs a new GeneratorPublisher with the specified async generator.

Uses of AsyncGenerator in org.bsc.async.v5

Classes in org.bsc.async.v5 that implement AsyncGenerator

Modifier and Type	Class	Description
static class	AsyncGeneratorFlow.Generator<E>	Inner class to generate asynchronous elements from the queue.