Skip navigation links
A C D E F G H J N P R S 

A

add(Callable<? extends CompletionStage<T>>) - Method in class com.spotify.futures.ConcurrencyReducer
the callable function will run as soon as the currently active set of futures is less than the maxConcurrency limit.
allAsList(List<? extends CompletionStage<? extends T>>) - Static method in class com.spotify.futures.CompletableFutures
Returns a new CompletableFuture which completes to a list of all values of its input stages, if all succeed.
andThen(Function<? super R, ? extends V>) - Method in interface com.spotify.futures.Function3
Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(Function<? super R, ? extends V>) - Method in interface com.spotify.futures.Function4
Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(Function<? super R, ? extends V>) - Method in interface com.spotify.futures.Function5
Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(Function<? super R, ? extends V>) - Method in interface com.spotify.futures.Function6
Returns a composed function that first applies this function to its input, and then applies the after function to the result.
apply(A, B, C) - Method in interface com.spotify.futures.Function3
Applies this function to the given arguments.
apply(A, B, C, D) - Method in interface com.spotify.futures.Function4
Applies this function to the given arguments.
apply(A, B, C, D, E) - Method in interface com.spotify.futures.Function5
Applies this function to the given arguments.
apply(A, B, C, D, E, F) - Method in interface com.spotify.futures.Function6
Applies this function to the given arguments.

C

CapacityReachedException(String) - Constructor for exception com.spotify.futures.ConcurrencyReducer.CapacityReachedException
 
checkCompleted(CompletionStage<?>) - Static method in class com.spotify.futures.CompletableFutures
Checks that a stage is completed.
com.spotify.futures - package com.spotify.futures
Extends the Java completable future API.
combine(CompletionStage<A>, CompletionStage<B>, BiFunction<A, B, R>) - Static method in class com.spotify.futures.CompletableFutures
Combines multiple stages by applying a function.
combine(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, Function3<A, B, C, R>) - Static method in class com.spotify.futures.CompletableFutures
Combines multiple stages by applying a function.
combine(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, Function4<A, B, C, D, R>) - Static method in class com.spotify.futures.CompletableFutures
Combines multiple stages by applying a function.
combine(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, CompletionStage<E>, Function5<A, B, C, D, E, R>) - Static method in class com.spotify.futures.CompletableFutures
Combines multiple stages by applying a function.
combine(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, CompletionStage<E>, CompletionStage<F>, Function6<A, B, C, D, E, F, R>) - Static method in class com.spotify.futures.CompletableFutures
Combines multiple stages by applying a function.
combineFutures(CompletionStage<A>, CompletionStage<B>, BiFunction<A, B, CompletionStage<R>>) - Static method in class com.spotify.futures.CompletableFutures
Composes multiple stages into another stage using a function.
combineFutures(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, Function3<A, B, C, CompletionStage<R>>) - Static method in class com.spotify.futures.CompletableFutures
Composes multiple stages into another stage using a function.
combineFutures(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, Function4<A, B, C, D, CompletionStage<R>>) - Static method in class com.spotify.futures.CompletableFutures
Composes multiple stages into another stage using a function.
combineFutures(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, CompletionStage<E>, Function5<A, B, C, D, E, CompletionStage<R>>) - Static method in class com.spotify.futures.CompletableFutures
Composes multiple stages into another stage using a function.
combineFutures(CompletionStage<A>, CompletionStage<B>, CompletionStage<C>, CompletionStage<D>, CompletionStage<E>, CompletionStage<F>, Function6<A, B, C, D, E, F, CompletionStage<R>>) - Static method in class com.spotify.futures.CompletableFutures
Composes multiple stages into another stage using a function.
CompletableFutures - Class in com.spotify.futures
A collection of static utility methods that extend the Java completable future API.
ConcurrencyReducer<T> - Class in com.spotify.futures
ConcurrencyReducer is used to queue tasks which will be executed in a manner reducing the number of concurrent tasks.
ConcurrencyReducer.CapacityReachedException - Exception in com.spotify.futures
 
create(int, int) - Static method in class com.spotify.futures.ConcurrencyReducer
 

D

dereference(CompletionStage<? extends CompletionStage<T>>) - Static method in class com.spotify.futures.CompletableFutures
This takes a stage of a stage of a value and returns a plain stage of a value.

E

exceptionallyCompletedFuture(Throwable) - Static method in class com.spotify.futures.CompletableFutures
Returns a new CompletableFuture that is already exceptionally completed with the given exception.
exceptionallyCompose(CompletionStage<T>, Function<Throwable, ? extends CompletionStage<T>>) - Static method in class com.spotify.futures.CompletableFutures
Returns a new stage that, when this stage completes exceptionally, is executed with this stage's exception as the argument to the supplied function.

F

Function3<A,B,C,R> - Interface in com.spotify.futures
Represents a function that accepts three arguments and produces a result.
Function4<A,B,C,D,R> - Interface in com.spotify.futures
Represents a function that accepts four arguments and produces a result.
Function5<A,B,C,D,E,R> - Interface in com.spotify.futures
Represents a function that accepts five arguments and produces a result.
Function6<A,B,C,D,E,F,R> - Interface in com.spotify.futures
Represents a function that accepts six arguments and produces a result.

G

getCompleted(CompletionStage<T>) - Static method in class com.spotify.futures.CompletableFutures
Gets the value of a completed stage.
getException(CompletionStage<T>) - Static method in class com.spotify.futures.CompletableFutures
Gets the exception from an exceptionally completed future

H

handleCompose(CompletionStage<T>, BiFunction<? super T, Throwable, ? extends CompletionStage<U>>) - Static method in class com.spotify.futures.CompletableFutures
Returns a new stage that, when this stage completes either normally or exceptionally, is executed with this stage's result and exception as arguments to the supplied function.

J

joinList() - Static method in class com.spotify.futures.CompletableFutures
Collect a stream of CompletionStages into a single future holding a list of the joined entities.

N

numActive() - Method in class com.spotify.futures.ConcurrencyReducer
 
numQueued() - Method in class com.spotify.futures.ConcurrencyReducer
 

P

poll(Supplier<Optional<T>>, Duration, ScheduledExecutorService) - Static method in class com.spotify.futures.CompletableFutures
Polls an external resource periodically until it returns a non-empty result.

R

remainingActiveCapacity() - Method in class com.spotify.futures.ConcurrencyReducer
 
remainingQueueCapacity() - Method in class com.spotify.futures.ConcurrencyReducer
 

S

successfulAsList(List<? extends CompletionStage<T>>, Function<Throwable, ? extends T>) - Static method in class com.spotify.futures.CompletableFutures
Returns a new CompletableFuture which completes to a list of values of those input stages that succeeded.
A C D E F G H J N P R S 
Skip navigation links

Copyright © 2018 Spotify AB. All rights reserved.