Index

A C D E F G 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(Executor) - Method in interface org.bsc.async.AsyncGenerator

async.generator - module async.generator

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

An asynchronous generator interface that allows generating asynchronous elements.

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

Represents a data element in the AsyncGenerator.

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

AsyncGenerator.EmbedCompletionHandler - Interface 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.

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

AsyncGeneratorQueue - Class in org.bsc.async

Represents a queue-based asynchronous generator.

AsyncGeneratorQueue() - Constructor for class org.bsc.async.AsyncGeneratorQueue

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

Inner class to generate asynchronous elements from the queue.

C

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

collect(Collection<E>, BiConsumer<E, Consumer<CompletableFuture<U>>>) - Static method in interface org.bsc.async.AsyncGenerator

Collects asynchronous elements from a collection.

collect(Iterator<E>, BiConsumer<E, Consumer<CompletableFuture<U>>>) - Static method in interface org.bsc.async.AsyncGenerator

Collects asynchronous elements from an iterator.

collectAsync(R, BiConsumer<R, E>) - Method in interface org.bsc.async.AsyncGeneratorOperators

Collects elements from the AsyncGenerator asynchronously into a list.

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

Deprecated.

Use async and then call AsyncGeneratorOperators.collectAsync(List, BiConsumer) collectAsync} for the desired functionality.

collectAsync(R, Consumer<E>, Executor) - Method in interface org.bsc.async.AsyncGenerator

Deprecated.

Use async and then call AsyncGeneratorOperators.collectAsync(List, BiConsumer) collectAsync} for the desired functionality.

composeWith(AsyncGenerator<E>, AsyncGenerator.EmbedCompletionHandler) - Static method in 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

D

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

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

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

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

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

E

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

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

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

Returns an empty AsyncGenerator.

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

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

F

filter(Predicate<E>) - Method in interface org.bsc.async.AsyncGeneratorOperators

Filters the elements of this generator based on the given predicate.

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

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.AsyncGeneratorOperators

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

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

Creates an AsyncGenerator from a Flow.Publisher.

G

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

Constructs a Generator with the specified queue.

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.

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

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

I

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

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

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

Returns an iterator over the elements of this AsyncGenerator.

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

M

map(Collection<E>, Function<E, CompletableFuture<U>>) - Static method in interface org.bsc.async.AsyncGenerator

create a generator, mapping each element to an asynchronous counterpart.

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

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

map(Iterator<E>, Function<E, CompletableFuture<U>>) - Static method in interface org.bsc.async.AsyncGenerator

create a generator, mapping each element to an asynchronous counterpart.

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 interface org.bsc.async.AsyncGeneratorOperators

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

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.

O

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

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

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

Deprecated.

use of(Q, Consumer, Executor)

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

Creates an AsyncGenerator from the provided blocking queue and consumer.

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

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.

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

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

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

Q

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

R

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

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

Retrieves the result value of the generator, if any.

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.

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

Converts an AsyncGenerator into a Flow.Publisher.

U

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

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

W

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 C D E F G I M N O P Q R S T U W
All Classes and Interfaces|All Packages