Uses of Class
cloud.opencode.base.parallel.pipeline.AsyncPipeline

Packages that use AsyncPipeline

Package	Description
cloud.opencode.base.parallel	OpenCode Parallel - Modern Parallel Computing Utilities OpenCode 并行 - 现代化并行计算工具
cloud.opencode.base.parallel.pipeline	Pipeline Package - Async Pipeline and Functions 流水线包 - 异步流水线和函数

Uses of AsyncPipeline in cloud.opencode.base.parallel

Methods in cloud.opencode.base.parallel that return AsyncPipeline

Modifier and Type	Method	Description
static <T> AsyncPipeline<T>	OpenParallel.pipeline(CompletableFuture<T> future)	Creates an async pipeline from existing future.
static <T> AsyncPipeline<T>	OpenParallel.pipeline(Supplier<T> initial)	Creates an async pipeline from initial supplier.

Uses of AsyncPipeline in cloud.opencode.base.parallel.pipeline

Methods in cloud.opencode.base.parallel.pipeline that return AsyncPipeline

Modifier and Type	Method	Description
<U,R> AsyncPipeline<R>	AsyncPipeline.combine(AsyncPipeline<U> other, BiFunction<T,U,R> combiner)	Combines with another pipeline.
static <T> AsyncPipeline<T>	AsyncPipeline.completed(T value)	Creates a pipeline with a completed value.
static <T> AsyncPipeline<T>	AsyncPipeline.failed(Throwable error)	Creates a pipeline with a failed value.
AsyncPipeline<T>	AsyncPipeline.filter(Predicate<T> predicate)	Filters the value.
<R> AsyncPipeline<R>	AsyncPipeline.handle(BiFunction<T, Throwable, R> handler)	Handles both success and error.
static <T> AsyncPipeline<T>	AsyncPipeline.of(CompletableFuture<T> future)	Creates a pipeline from a CompletableFuture.
AsyncPipeline<T>	AsyncPipeline.onError(Function<Throwable, T> handler)	Handles errors with a recovery function.
AsyncPipeline<T>	AsyncPipeline.onErrorAsync(Function<Throwable, CompletableFuture<T>> handler)	Handles errors with an async recovery function.
AsyncPipeline<T>	AsyncPipeline.peek(Consumer<T> action)	Peeks at the value without transforming it.
AsyncPipeline<T>	AsyncPipeline.runAfter(AsyncPipeline<?> other)	Runs after another pipeline completes.
<R> AsyncPipeline<R>	AsyncPipeline.then(Function<T,R> fn)	Applies a transformation function.
<R> AsyncPipeline<R>	AsyncPipeline.thenAsync(Function<T, CompletableFuture<R>> fn)	Applies an async transformation function.

Methods in cloud.opencode.base.parallel.pipeline with parameters of type AsyncPipeline

Modifier and Type	Method	Description
<U,R> AsyncPipeline<R>	AsyncPipeline.combine(AsyncPipeline<U> other, BiFunction<T,U,R> combiner)	Combines with another pipeline.
AsyncPipeline<T>	AsyncPipeline.runAfter(AsyncPipeline<?> other)	Runs after another pipeline completes.