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

Packages that use AsyncGenerator.Data

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

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, Consumer<Q> consumer)	Deprecated, for removal: This API element is subject to removal in a future version. 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)	Deprecated, for removal: This API element is subject to removal in a future version. 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> future)

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

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.
	GeneratorSubscriber(P publisher, Supplier<Object> mapResult, BlockingQueue<AsyncGenerator.Data<T>> queue)	Constructs a new instance of GeneratorSubscriber.

Uses of AsyncGenerator.Data in org.bsc.async.v5

Methods in org.bsc.async.v5 that return AsyncGenerator.Data

Modifier and Type	Method	Description
AsyncGenerator.Data<E>	AsyncGeneratorFlow.Generator.next()	Retrieves the next element from the queue asynchronously.
AsyncGenerator.Data<E>	AsyncGeneratorFlow.Receiver.waitSync()
AsyncGenerator.Data<E>	BlockingQueueProcessor.waitSync()

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

Modifier and Type	Method	Description
BlockingQueue<AsyncGenerator.Data<E>>	BlockingQueueProcessor.queue()	Returns the value of the queue record component.
Optional<AsyncGenerator.Data<E>>	AsyncGeneratorFlow.Receiver.waitAsync()
Optional<AsyncGenerator.Data<E>>	BlockingQueueProcessor.waitAsync()

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

Modifier and Type	Method	Description
void	AsyncGeneratorFlow.Dispatcher.dispatchAsync(AsyncGenerator.Data<E> data)
void	BlockingQueueProcessor.dispatchAsync(AsyncGenerator.Data<E> data)
void	AsyncGeneratorFlow.Dispatcher.dispatchSync(AsyncGenerator.Data<E> data)
void	BlockingQueueProcessor.dispatchSync(AsyncGenerator.Data<E> data)

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

Modifier	Constructor	Description
	BlockingQueueProcessor(BlockingQueue<AsyncGenerator.Data<E>> queue)	Creates an instance of a BlockingQueueProcessor record class.