Uses of Class
cloud.opencode.base.functional.async.Future

Packages that use Future

Package	Description
cloud.opencode.base.functional.async	Async Utilities - Virtual Thread functional utilities 异步工具 - 虚拟线程函数式工具

Uses of Future in cloud.opencode.base.functional.async

Methods in cloud.opencode.base.functional.async that return Future

Modifier and Type	Method	Description
<R> Future<R>	Future.andThenVirtual(Function<? super T, ? extends R> action)	Run action after completion on a virtual thread.
static <T> Future<T>	Future.failed(Throwable exception)	Create a failed Future with the given exception.
Future<T>	Future.filter(Predicate<? super T> predicate)	Filter the value.
static <T> Future<T>	Future.firstCompleted(Future<T>... futures)	Return the first completed future.
<R> Future<R>	Future.flatMap(Function<? super T, ? extends Future<R>> mapper)	FlatMap to another Future.
<R> Future<R>	Future.flatMapVirtual(Function<? super T, ? extends Future<R>> mapper)	FlatMap on virtual thread.
static <T> Future<T>	Future.fromCallable(Callable<T> callable)	Create a Future from a callable.
static <T> Future<T>	Future.fromCompletableFuture(CompletableFuture<T> cf)	Create a Future from a CompletableFuture.
<R> Future<R>	Future.map(Function<? super T, ? extends R> mapper)	Map the value to a new value.
static <T> Future<T>	Future.never()	Create a Future that never completes.
static <T> Future<T>	Future.of(Supplier<T> supplier)	Create a Future from a supplier (uses ForkJoinPool).
static <T> Future<T>	Future.of(Supplier<T> supplier, Executor executor)	Create a Future from a supplier with custom executor.
static <T> Future<T>	Future.ofVirtual(Supplier<T> supplier)	Create a Future from a supplier using virtual threads.
Future<T>	Future.onComplete(BiConsumer<? super T, ? super Throwable> action)	Execute side effect on completion.
Future<T>	Future.onFailure(Consumer<? super Throwable> action)	Execute side effect on failure.
Future<T>	Future.onSuccess(Consumer<? super T> action)	Execute side effect on success.
Future<T>	Future.orElse(Future<T> fallback)	Provide a fallback Future on failure.
Future<T>	Future.orElse(T fallback)	Provide a fallback value on failure.
<E extends Throwable> Future<T>	Future.recover(Class<E> exceptionType, Function<? super E, ? extends T> recovery)	Recover from specific exception type.
Future<T>	Future.recover(Function<? super Throwable, ? extends T> recovery)	Recover from any failure.
Future<T>	Future.recoverWith(Function<? super Throwable, ? extends Future<T>> recovery)	Recover with another Future.
static <T> Future<List<T>>	Future.sequence(Future<T>... futures)	Combine a list of futures into a future of list.
static <T> Future<List<T>>	Future.sequence(List<Future<T>> futures)	Combine a list of futures into a future of list.
static <T> Future<T>	Future.successful(T value)	Create a successful Future with the given value.
Future<T>	Future.timeout(Duration duration)	Apply a timeout to this Future.
Future<T>	Future.timeout(Duration duration, T defaultValue)	Apply a timeout with default value.
static <A,B> Future<List<B>>	Future.traverse(Iterable<A> items, Function<? super A, ? extends Future<B>> function)	Transform a collection into a future of list using a mapping function.
static <A,B,R> Future<R>	Future.zip(Future<A> futureA, Future<B> futureB, BiFunction<? super A, ? super B, ? extends R> zipper)	Zip two futures into one.
<U,R> Future<R>	Future.zipWith(Future<U> other, BiFunction<? super T, ? super U, ? extends R> zipper)	Zip this future with another.

Methods in cloud.opencode.base.functional.async with parameters of type Future

Modifier and Type	Method	Description
static <T> Future<T>	Future.firstCompleted(Future<T>... futures)	Return the first completed future.
Future<T>	Future.orElse(Future<T> fallback)	Provide a fallback Future on failure.
static <T> Future<List<T>>	Future.sequence(Future<T>... futures)	Combine a list of futures into a future of list.
static <A,B,R> Future<R>	Future.zip(Future<A> futureA, Future<B> futureB, BiFunction<? super A, ? super B, ? extends R> zipper)	Zip two futures into one.
<U,R> Future<R>	Future.zipWith(Future<U> other, BiFunction<? super T, ? super U, ? extends R> zipper)	Zip this future with another.

Method parameters in cloud.opencode.base.functional.async with type arguments of type Future

Modifier and Type	Method	Description
<R> Future<R>	Future.flatMap(Function<? super T, ? extends Future<R>> mapper)	FlatMap to another Future.
<R> Future<R>	Future.flatMapVirtual(Function<? super T, ? extends Future<R>> mapper)	FlatMap on virtual thread.
Future<T>	Future.recoverWith(Function<? super Throwable, ? extends Future<T>> recovery)	Recover with another Future.
static <T> Future<List<T>>	Future.sequence(List<Future<T>> futures)	Combine a list of futures into a future of list.
static <A,B> Future<List<B>>	Future.traverse(Iterable<A> items, Function<? super A, ? extends Future<B>> function)	Transform a collection into a future of list using a mapping function.