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

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.

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 <T, P extends Flow.Publisher<T>> AsyncGenerator<T>	FlowGenerator.fromPublisher(P publisher)	Creates an AsyncGenerator from a Flow.Publisher.
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)
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.