Uses of Interface
org.bsc.async.AsyncGenerator

Uses of AsyncGenerator in org.bsc.async

Classes in org.bsc.async that implement AsyncGenerator

Modifier and Type	Class	Description
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.

Fields in org.bsc.async declared as AsyncGenerator

Modifier and Type	Field	Description
protected AsyncGenerator<E>	AsyncGenerator.WithResult.delegate

Methods in org.bsc.async that return AsyncGenerator

Modifier and Type	Method	Description
static <E,U> AsyncGenerator<U>	AsyncGenerator.collect(Collection<E> collection, BiConsumer<E,Consumer<CompletableFuture<U>>> consumer)	Collects asynchronous elements from a collection.
static <E,U> AsyncGenerator<U>	AsyncGenerator.collect(Iterator<E> iterator, BiConsumer<E,Consumer<CompletableFuture<U>>> consumer)	Collects asynchronous elements from an iterator.
AsyncGenerator<E>	AsyncGenerator.WithResult.delegate()
static <E> AsyncGenerator<E>	AsyncGenerator.empty()	Returns an empty AsyncGenerator.
default AsyncGenerator<E>	AsyncGeneratorOperators.filter(Predicate<E> predicate)	Filters the elements of this generator based on the given predicate.
default <U> AsyncGenerator<U>	AsyncGeneratorOperators.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,U> AsyncGenerator<U>	AsyncGenerator.map(Collection<E> collection, Function<E,CompletableFuture<U>> mapFunction)	create a generator, mapping each element to an asynchronous counterpart.
static <E,U> AsyncGenerator<U>	AsyncGenerator.map(Iterator<E> iterator, Function<E,CompletableFuture<U>> mapFunction)	create a generator, mapping each element to an asynchronous counterpart.
default <U> AsyncGenerator<U>	AsyncGeneratorOperators.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, Executor executor, Consumer<Q> consumer)	Deprecated. use of(Q, Consumer, Executor)
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)

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

Constructor	Description
Embed(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)
WithEmbed(AsyncGenerator<E> delegate)
WithEmbed(AsyncGenerator<E> delegate, AsyncGenerator.EmbedCompletionHandler onGeneratorDoneWithResult)
WithResult(AsyncGenerator<E> delegate)