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

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

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.

B

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

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

C

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

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

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

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

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

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

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

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 class org.bsc.async.AsyncGenerator.Embed

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.

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

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.

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

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.

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

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

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

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

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

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 record class org.bsc.async.AsyncGenerator.Data

Returns the value of the resultValue record component.

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

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

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

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.

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