Uses of Class
org.bsc.async.AsyncGenerator.Data

Uses of AsyncGenerator.Data in org.bsc.async

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

Modifier and Type	Method	Description
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 that return AsyncGenerator.Data

Modifier and Type	Method	Description
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.composeWith(AsyncGenerator<E> generator, AsyncGenerator.EmbedCompletionHandler onCompletion)
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.done()
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.done(Object resultValue)
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.error(Throwable exception)
AsyncGenerator.Data<E>	AsyncGenerator.next()	Retrieves the next asynchronous element.
AsyncGenerator.Data<E>	AsyncGenerator.WithEmbed.next()
AsyncGenerator.Data<E>	AsyncGenerator.WithResult.next()
AsyncGenerator.Data<E>	AsyncGeneratorQueue.Generator.next()	Retrieves the next element from the queue asynchronously.
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.of(E data)
static <E> AsyncGenerator.Data<E>	AsyncGenerator.Data.of(CompletableFuture<E> data)

Methods in org.bsc.async that return types with arguments of type AsyncGenerator.Data

Modifier and Type	Method	Description
BlockingQueue<AsyncGenerator.Data<E>>	AsyncGeneratorQueue.Generator.queue()
Deque<AsyncGenerator.Data<E>>	AsyncGenerator.WithEmbed.resultValues()

Constructor parameters in org.bsc.async with type arguments of type AsyncGenerator.Data

Constructor	Description
Generator(BlockingQueue<AsyncGenerator.Data<E>> queue)	Constructs a Generator with the specified queue.