如何将过滤器集合应用到 Java 流？

Question

如何将谓词集合应用到 Java 流？

下面的代码将说明我的想法：

final Collection<Predicate<MyObject>> filters = getFilters();
final Stream<MyObject> oStream = getMyObjectStream();
oStream
   .filterAll(filters) // <- this one doesn't exist
   .forEach(System.out::println);

我目前正在使用带有经典循环的函数.filter(m -> applyAllFilters(m, filters))，但想知道是否有更“流式”的方式？

boolean applyAllFilters(final MyObject m, final Collection<Predicate<MyObject>> filters) {
   Iterator Predicate<MyObject> iter = filters.iterator();
   while(iter.hasNext()) {
      Predicate<MyObject> p = iter.next();
      if (!p.test(m)) {
         return false;
      }
   } 
  return true;
}

Answer 1

您可以简单地将所有谓词简化为一个与所有谓词进行与运算的谓词，如下所示：

oStream
    .filter(filters.stream().reduce(Predicate::and).orElseThrow())
    .forEach(System.out::println);

或者，如果您希望过滤器列表在某些情况下为空，您可以这样做：

oStream
    .filter(filters.stream().reduce(o -> true, Predicate::and))
    .forEach(System.out::println);