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

Packages that use AsyncGenerator.Data

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

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()
final AsyncGenerator.Data<E>	AsyncGenerator.WithResult.next()
AsyncGenerator.Data<E>	AsyncGeneratorOperators.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

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

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

Methods in org.bsc.async.internal.reactive that return AsyncGenerator.Data

Modifier and Type	Method	Description
AsyncGenerator.Data<T>	GeneratorSubscriber.next()	Returns the next Data<T> object from this iteration.

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

Modifier	Constructor	Description
	GeneratorSubscriber(P publisher, BlockingQueue<AsyncGenerator.Data<T>> queue)	Constructs a new instance of GeneratorSubscriber.