任何不丢弃的类似于滤波器的lambda操作？

Question

我基本上想做类似的事情：

  assertEquals(Arrays.asList(1,2,3).stream()
                                   .noDiscardingFilter(x -> x!=1)
                                   .map(x -> x*10)
                                   .collect(Collectors.toList()),  
                Arrays.asList(1,20,30)
              )

这是一个示例，我不需要获取有关如何解决该特定问题的答案，它只是一个示例，它说明了我所追求的东西。

Answer 1

任何中间步骤都会影响整个流管道。您的愿望背后没有可识别的规则，即该noDiscardingFilter步骤会影响随后链接的map操作，但不会影响collect操作。如果要具有条件函数，则将其实现为这样会更加清晰：

public static <T> Function<T,T> conditional(
                                Predicate<? super T> p, Function<T, ? extends T> f) {
    return obj -> p.test(obj)? f.apply(obj): obj;
}

这可以用作

assertEquals(Stream.of(1, 2, 3)
        .map(conditional(x -> x!=1, x -> x*10))
        .collect(Collectors.toList()),
    Arrays.asList(1, 20, 30)
);

要么

Stream.of(1, 5, null, 3, null, 4)
      .map(conditional(Objects::isNull, x -> 0)) // replacing null with default value
      .forEach(System.out::println);

要么

Stream.of(1, 5, null, 3, null, 4)
      .map(conditional(Objects::nonNull, x -> x*10)) // null-safe calculation
      .forEach(System.out::println);

请注意，在这些用例中，如何立即识别出传递给的谓词和函数conditional属于同一作用域，这与链式流操作不同。