Index

A B C D E F G H I M N O P Q R S T U W
All Classes and Interfaces|All Packages

A

accept(Object) - Method in interface org.bsc.async.AsyncGenerator.EmbedCompletionHandler

add(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

addAll(Collection<? extends T>) - Method in class org.bsc.async.internal.UnmodifiableDeque

addFirst(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

addLast(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

async.generator - module async.generator

AsyncGenerator<E> - Interface in org.bsc.async

An asynchronous generator interface that allows generating asynchronous elements.

AsyncGenerator.Base<E> - Class in org.bsc.async

Abstract base class for AsyncGenerator implementations.

AsyncGenerator.BaseCancellable<E> - Class in org.bsc.async

AsyncGenerator.Cancellable<E> - Interface in org.bsc.async

AsyncGenerator.Data<E> - Record Class in org.bsc.async

Represents a data element in the AsyncGenerator.

AsyncGenerator.Embed<E> - Record Class in org.bsc.async

AsyncGenerator.EmbedCompletionHandler - Interface in org.bsc.async

AsyncGenerator.HasResultValue - Interface in org.bsc.async

AsyncGenerator.IsCancellable - Interface in org.bsc.async

AsyncGenerator.ReduceResult<E> - Record Class in org.bsc.async

AsyncGenerator.WithEmbed<E> - Class in org.bsc.async

An asynchronous generator decorator that allows to generators composition embedding other generators.

AsyncGenerator.WithResult<E> - Class in org.bsc.async

An asynchronous generator decorator that allows retrieving the result value of the asynchronous operation, if any.

AsyncGeneratorFlow - Interface in org.bsc.async.v5

Represents a queue-based asynchronous generator.

AsyncGeneratorFlow.Builder - Class in org.bsc.async.v5

AsyncGeneratorFlow.Dispatcher<E> - Interface in org.bsc.async.v5

AsyncGeneratorFlow.Generator<E> - Class in org.bsc.async.v5

Inner class to generate asynchronous elements from the queue.

AsyncGeneratorFlow.Processor<E> - Interface in org.bsc.async.v5

AsyncGeneratorFlow.Receiver<E> - Interface in org.bsc.async.v5

AsyncGeneratorQueue - Interface in org.bsc.async

Deprecated, for removal: This API element is subject to removal in a future version.

use AsyncGeneratorFlow instead

AsyncGeneratorQueue.Generator<E> - Class in org.bsc.async

Deprecated.

Inner class to generate asynchronous elements from the queue.

B

BaseCancellable() - Constructor for class org.bsc.async.AsyncGenerator.BaseCancellable

BlockingQueueProcessor<E> - Record Class in org.bsc.async.v5

BlockingQueueProcessor() - Constructor for record class org.bsc.async.v5.BlockingQueueProcessor

BlockingQueueProcessor(BlockingQueue<AsyncGenerator.Data<E>>) - Constructor for record class org.bsc.async.v5.BlockingQueueProcessor

Creates an instance of a BlockingQueueProcessor record class.

build() - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Builder

build(Consumer<AsyncGeneratorFlow.Dispatcher<E>>) - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Builder

builder() - Static method in interface org.bsc.async.v5.AsyncGeneratorFlow

Builder() - Constructor for class org.bsc.async.v5.AsyncGeneratorFlow.Builder

C

cancel(boolean) - Method in class org.bsc.async.AsyncGenerator.BaseCancellable

Requests cancellation of the generator.

cancel(boolean) - Method in interface org.bsc.async.AsyncGenerator.IsCancellable

method that request to cancel generator

cancel(boolean) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

cancel(boolean) - Method in class org.bsc.async.AsyncGenerator.WithResult

cancel(boolean) - Method in class org.bsc.async.AsyncGeneratorQueue.Generator

Deprecated.

cancel(boolean) - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

cancel(boolean) - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Generator

CANCELLED - Static variable in interface org.bsc.async.AsyncGenerator.IsCancellable

clear() - Method in class org.bsc.async.internal.UnmodifiableDeque

close() - Method in class org.bsc.async.AsyncGenerator.Base

Closes this AsyncGenerator and releases its resources.

composeWith(AsyncGenerator<E>, AsyncGenerator.EmbedCompletionHandler) - Static method in record class org.bsc.async.AsyncGenerator.Data

contains(Object) - Method in class org.bsc.async.internal.UnmodifiableDeque

containsAll(Collection<?>) - Method in class org.bsc.async.internal.UnmodifiableDeque

create(Consumer<AsyncGeneratorFlow.Dispatcher<E>>) - Static method in interface org.bsc.async.v5.AsyncGeneratorFlow

create(AsyncGeneratorFlow.Processor<E>) - Static method in interface org.bsc.async.v5.AsyncGeneratorFlow

D

Data(CompletableFuture<E>, AsyncGenerator.Embed<E>, Object) - Constructor for record class org.bsc.async.AsyncGenerator.Data

Creates an instance of a Data record class.

delegate() - Method in class org.bsc.async.AsyncGenerator.WithResult

descendingIterator() - Method in class org.bsc.async.internal.UnmodifiableDeque

dispatchAsync(AsyncGenerator.Data<E>) - Method in interface org.bsc.async.v5.AsyncGeneratorFlow.Dispatcher

dispatchAsync(AsyncGenerator.Data<E>) - Method in record class org.bsc.async.v5.BlockingQueueProcessor

dispatchSync(AsyncGenerator.Data<E>) - Method in interface org.bsc.async.v5.AsyncGeneratorFlow.Dispatcher

dispatchSync(AsyncGenerator.Data<E>) - Method in record class org.bsc.async.v5.BlockingQueueProcessor

done() - Static method in record class org.bsc.async.AsyncGenerator.Data

done(Object) - Static method in record class org.bsc.async.AsyncGenerator.Data

E

element() - Method in class org.bsc.async.internal.UnmodifiableDeque

embed() - Method in record class org.bsc.async.AsyncGenerator.Data

Returns the value of the embed record component.

Embed(AsyncGenerator<E>, AsyncGenerator.EmbedCompletionHandler) - Constructor for record class org.bsc.async.AsyncGenerator.Embed

Creates an instance of a Embed record class.

empty() - Static method in interface org.bsc.async.AsyncGenerator

Returns an empty AsyncGenerator.

equals(Object) - Method in record class org.bsc.async.AsyncGenerator.Data

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.bsc.async.AsyncGenerator.Embed

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.bsc.async.AsyncGenerator.ReduceResult

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.bsc.async.v5.BlockingQueueProcessor

Indicates whether some other object is "equal to" this one.

error(Throwable) - Static method in record class org.bsc.async.AsyncGenerator.Data

executor() - Method in class org.bsc.async.AsyncGenerator.Base

executor() - Method in interface org.bsc.async.AsyncGenerator

executor() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

executor() - Method in class org.bsc.async.AsyncGenerator.WithResult

executor() - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

executor(Executor) - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Builder

F

flatMap(Function<E, CompletableFuture<U>>) - Method in interface org.bsc.async.AsyncGenerator

Maps the elements of this generator to a new asynchronous generator, and flattens the resulting nested generators.

FlowGenerator - Interface in org.bsc.async

Provides methods for converting between FlowGenerator and various Flow.Publisher types.

forEachAsync(Consumer<E>) - Method in interface org.bsc.async.AsyncGenerator

Asynchronously iterates over the elements of the AsyncGenerator and applies the given consumer to each element.

forEachAsync(Consumer<E>) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

from(Iterator<E>) - Static method in interface org.bsc.async.AsyncGenerator

Collects asynchronous elements from an iterator.

fromPublisher(P) - Static method in interface org.bsc.async.FlowGenerator

Creates an AsyncGenerator from a Flow.Publisher.

fromPublisher(P, Supplier<R>) - Static method in interface org.bsc.async.FlowGenerator

Creates an AsyncGenerator from a Flow.Publisher.

future() - Method in record class org.bsc.async.AsyncGenerator.Data

Returns the value of the future record component.

G

generator() - Method in record class org.bsc.async.AsyncGenerator.Embed

Returns the value of the generator record component.

Generator(BlockingQueue<AsyncGenerator.Data<E>>) - Constructor for class org.bsc.async.AsyncGeneratorQueue.Generator

Deprecated.

Constructs a Generator with the specified queue.

Generator(AsyncGeneratorFlow.Receiver<E>) - Constructor for class org.bsc.async.v5.AsyncGeneratorFlow.Generator

GeneratorPublisher<T> - Class in org.bsc.async.internal.reactive

A GeneratorPublisher is a Flow.Publisher that generates items from an asynchronous generator.

GeneratorPublisher(AsyncGenerator<? extends T>) - Constructor for class org.bsc.async.internal.reactive.GeneratorPublisher

Constructs a new GeneratorPublisher with the specified async generator.

GeneratorSubscriber<T> - Class in org.bsc.async.internal.reactive

Represents a subscriber for generating asynchronous data streams.

GeneratorSubscriber(P, BlockingQueue<AsyncGenerator.Data<T>>) - Constructor for class org.bsc.async.internal.reactive.GeneratorSubscriber

Constructs a new instance of GeneratorSubscriber.

GeneratorSubscriber(P, Supplier<Object>, BlockingQueue<AsyncGenerator.Data<T>>) - Constructor for class org.bsc.async.internal.reactive.GeneratorSubscriber

Constructs a new instance of GeneratorSubscriber.

getFirst() - Method in class org.bsc.async.internal.UnmodifiableDeque

getLast() - Method in class org.bsc.async.internal.UnmodifiableDeque

H

hashCode() - Method in record class org.bsc.async.AsyncGenerator.Data

Returns a hash code value for this object.

hashCode() - Method in record class org.bsc.async.AsyncGenerator.Embed

Returns a hash code value for this object.

hashCode() - Method in record class org.bsc.async.AsyncGenerator.ReduceResult

Returns a hash code value for this object.

hashCode() - Method in record class org.bsc.async.v5.BlockingQueueProcessor

Returns a hash code value for this object.

I

isCancelled() - Method in class org.bsc.async.AsyncGenerator.BaseCancellable

isCancelled() - Method in interface org.bsc.async.AsyncGenerator.IsCancellable

Checks if the asynchronous generation has been cancelled.

isCancelled() - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

isClosed() - Method in class org.bsc.async.AsyncGenerator.Base

Checks if this generator has been closed.

isDone() - Method in record class org.bsc.async.AsyncGenerator.Data

isEmpty() - Method in class org.bsc.async.internal.UnmodifiableDeque

isError() - Method in record class org.bsc.async.AsyncGenerator.Data

iterator() - Method in interface org.bsc.async.AsyncGenerator

Returns an iterator over the elements of this AsyncGenerator.

iterator() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

iterator() - Method in class org.bsc.async.internal.UnmodifiableDeque

M

map(Function<E, U>) - Method in interface org.bsc.async.AsyncGenerator

Maps the elements of this generator to a new asynchronous generator.

mapResult() - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

N

next() - Method in interface org.bsc.async.AsyncGenerator

Retrieves the next asynchronous element.

next() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

next() - Method in class org.bsc.async.AsyncGenerator.WithResult

next() - Method in class org.bsc.async.AsyncGeneratorQueue.Generator

Deprecated.

Retrieves the next element from the queue asynchronously.

next() - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

Returns the next Data<T> object from this iteration.

next() - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Generator

Retrieves the next element from the queue asynchronously.

O

of(E) - Static method in record class org.bsc.async.AsyncGenerator.Data

of(CompletableFuture<E>) - Static method in record class org.bsc.async.AsyncGenerator.Data

of(Q, Consumer<Q>) - Static method in interface org.bsc.async.AsyncGeneratorQueue

Deprecated.

Creates an AsyncGenerator from the provided blocking queue and consumer.

of(Q, Consumer<Q>, Executor) - Static method in interface org.bsc.async.AsyncGeneratorQueue

Deprecated.

Creates an AsyncGenerator from the provided queue, executor, and consumer.

offer(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

offerFirst(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

offerLast(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

onComplete() - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

This method is called when the asynchronous operation is completed successfully.

onCompletion() - Method in record class org.bsc.async.AsyncGenerator.Embed

Returns the value of the onCompletion record component.

onError(Throwable) - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

Handles an error by queuing it in the delegate's queue with an errored data.

onNext(T) - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

Passes the received item to the delegated queue as an AsyncGenerator.Data object.

onSubscribe(Flow.Subscription) - Method in class org.bsc.async.internal.reactive.GeneratorSubscriber

Handles the subscription event from a Flux.

org.bsc.async - package org.bsc.async

org.bsc.async.internal - package org.bsc.async.internal

org.bsc.async.internal.reactive - package org.bsc.async.internal.reactive

org.bsc.async.v5 - package org.bsc.async.v5

P

peek() - Method in class org.bsc.async.internal.UnmodifiableDeque

peekFirst() - Method in class org.bsc.async.internal.UnmodifiableDeque

peekLast() - Method in class org.bsc.async.internal.UnmodifiableDeque

poll() - Method in class org.bsc.async.internal.UnmodifiableDeque

pollFirst() - Method in class org.bsc.async.internal.UnmodifiableDeque

pollLast() - Method in class org.bsc.async.internal.UnmodifiableDeque

pop() - Method in class org.bsc.async.internal.UnmodifiableDeque

processor(AsyncGeneratorFlow.Processor<E>) - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Builder

push(T) - Method in class org.bsc.async.internal.UnmodifiableDeque

Q

queue() - Method in class org.bsc.async.AsyncGeneratorQueue.Generator

Deprecated.

queue() - Method in record class org.bsc.async.v5.BlockingQueueProcessor

Returns the value of the queue record component.

R

receiver() - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Generator

reduce(BinaryOperator<E>) - Method in interface org.bsc.async.AsyncGenerator

reduce(BinaryOperator<E>) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

reduce(R, BiFunction<R, E, R>) - Method in interface org.bsc.async.AsyncGenerator

reduce(R, BiFunction<R, E, R>) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

reduceAsync(BinaryOperator<E>) - Method in interface org.bsc.async.AsyncGenerator

reduceAsync(BinaryOperator<E>) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

reduceAsync(R, BiFunction<R, E, R>) - Method in interface org.bsc.async.AsyncGenerator

reduceAsync(R, BiFunction<R, E, R>) - Method in class org.bsc.async.AsyncGenerator.WithEmbed

ReduceResult(E, Object) - Constructor for record class org.bsc.async.AsyncGenerator.ReduceResult

Creates an instance of a ReduceResult record class.

remove() - Method in class org.bsc.async.internal.UnmodifiableDeque

remove(Object) - Method in class org.bsc.async.internal.UnmodifiableDeque

removeAll(Collection<?>) - Method in class org.bsc.async.internal.UnmodifiableDeque

removeFirst() - Method in class org.bsc.async.internal.UnmodifiableDeque

removeFirstOccurrence(Object) - Method in class org.bsc.async.internal.UnmodifiableDeque

removeLast() - Method in class org.bsc.async.internal.UnmodifiableDeque

removeLastOccurrence(Object) - Method in class org.bsc.async.internal.UnmodifiableDeque

result() - Method in record class org.bsc.async.AsyncGenerator.ReduceResult

Returns the value of the result record component.

resultValue() - Method in record class org.bsc.async.AsyncGenerator.Data

Returns the value of the resultValue record component.

resultValue() - Method in record class org.bsc.async.AsyncGenerator.Embed

resultValue() - Method in interface org.bsc.async.AsyncGenerator.HasResultValue

resultValue() - Method in record class org.bsc.async.AsyncGenerator.ReduceResult

Returns the value of the resultValue record component.

resultValue() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

resultValue() - Method in class org.bsc.async.AsyncGenerator.WithResult

Retrieves the result value of the generator, if any.

resultValue() - Method in class org.bsc.async.v5.AsyncGeneratorFlow.Generator

resultValue(Iterator<?>) - Static method in interface org.bsc.async.AsyncGenerator

resultValue(AsyncGenerator<?>) - Static method in interface org.bsc.async.AsyncGenerator

resultValues() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

retainAll(Collection<?>) - Method in class org.bsc.async.internal.UnmodifiableDeque

S

size() - Method in class org.bsc.async.internal.UnmodifiableDeque

stream() - Method in interface org.bsc.async.AsyncGenerator

Returns a sequential Stream with the elements of this AsyncGenerator.

subscribe(Flow.Subscriber<? super T>) - Method in class org.bsc.async.internal.reactive.GeneratorPublisher

Subscribes the provided Flow.Subscriber to this signal.

T

toArray() - Method in class org.bsc.async.internal.UnmodifiableDeque

toArray(T1[]) - Method in class org.bsc.async.internal.UnmodifiableDeque

toCompletableFuture() - Method in interface org.bsc.async.AsyncGenerator

Converts the AsyncGenerator to a CompletableFuture.

toCompletableFuture() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

toCompletableFutureAsync() - Method in interface org.bsc.async.AsyncGenerator

toCompletableFutureAsync() - Method in class org.bsc.async.AsyncGenerator.WithEmbed

toPublisher(AsyncGenerator<T>) - Static method in interface org.bsc.async.FlowGenerator

Converts an AsyncGenerator into a Flow.Publisher.

toString() - Method in record class org.bsc.async.AsyncGenerator.Data

Returns a string representation of this record class.

toString() - Method in record class org.bsc.async.AsyncGenerator.Embed

Returns a string representation of this record class.

toString() - Method in record class org.bsc.async.AsyncGenerator.ReduceResult

Returns a string representation of this record class.

toString() - Method in record class org.bsc.async.v5.BlockingQueueProcessor

Returns a string representation of this record class.

U

UnmodifiableDeque<T> - Class in org.bsc.async.internal

UnmodifiableDeque(Deque<T>) - Constructor for class org.bsc.async.internal.UnmodifiableDeque

W

waitAsync() - Method in interface org.bsc.async.v5.AsyncGeneratorFlow.Receiver

waitAsync() - Method in record class org.bsc.async.v5.BlockingQueueProcessor

waitSync() - Method in interface org.bsc.async.v5.AsyncGeneratorFlow.Receiver

waitSync() - Method in record class org.bsc.async.v5.BlockingQueueProcessor

WithEmbed(AsyncGenerator<E>) - Constructor for class org.bsc.async.AsyncGenerator.WithEmbed

WithEmbed(AsyncGenerator<E>, AsyncGenerator.EmbedCompletionHandler) - Constructor for class org.bsc.async.AsyncGenerator.WithEmbed

WithResult(AsyncGenerator<E>) - Constructor for class org.bsc.async.AsyncGenerator.WithResult

A B C D E F G H I M N O P Q R S T U W
All Classes and Interfaces|All Packages