Uses of Interface
org.bsc.async.AsyncGenerator

Packages that use AsyncGenerator

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

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>
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>	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.
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)	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)	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)
	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.