Class Pipeline.CollectionPipeline<T,R>

java.lang.Object
cloud.opencode.base.functional.pipeline.Pipeline.CollectionPipeline<T,R>
Type Parameters:
T - input element type - 输入元素类型
R - output element type - 输出元素类型
Enclosing class:
Pipeline<T,R>

public static final class Pipeline.CollectionPipeline<T,R> extends Object
CollectionPipeline - Pipeline for processing collections CollectionPipeline - 用于处理集合的管道
Since:
JDK 25, opencode-base-functional V1.0.0
Author:
Leon Soo www.LeonSoo.com
  • Method Details

    • map

      public <U> Pipeline.CollectionPipeline<T,U> map(Function<? super R, ? extends U> mapper)
      Transform each element 转换每个元素
      Type Parameters:
      U - result type - 结果类型
      Parameters:
      mapper - transformation function - 转换函数
      Returns:
      pipeline with transformation
    • filter

      public Pipeline.CollectionPipeline<T,R> filter(Predicate<? super T> predicate)
      Filter elements 过滤元素
      Parameters:
      predicate - filter condition - 过滤条件
      Returns:
      filtered pipeline
    • toList

      public List<R> toList()
      Execute and collect to List 执行并收集为 List
      Returns:
      list of results
    • forEach

      public void forEach(Consumer<? super R> action)
      Execute and perform action on each 执行并对每个元素执行动作
      Parameters:
      action - action to perform - 要执行的动作
    • count

      public long count()
      Execute and count results 执行并计数结果
      Returns:
      count of elements
    • findFirst

      public Optional<R> findFirst()
      Find first matching element 查找第一个匹配元素
      Returns:
      Optional containing first element
    • anyMatch

      public boolean anyMatch(Predicate<? super R> predicate)
      Check if any element matches 检查是否有任何元素匹配
      Parameters:
      predicate - match condition - 匹配条件
      Returns:
      true if any match
    • allMatch

      public boolean allMatch(Predicate<? super R> predicate)
      Check if all elements match 检查是否所有元素都匹配
      Parameters:
      predicate - match condition - 匹配条件
      Returns:
      true if all match
    • reduce

      public R reduce(R identity, BinaryOperator<R> accumulator)
      Reduce elements to single value 将元素规约为单个值
      Parameters:
      identity - identity value - 恒等值
      accumulator - accumulator function - 累加器函数
      Returns:
      reduced value