在参数中给定多个条件时过滤流

Question

我试图创建一个函数，该函数接受多个谓词条件，并根据这些条件过滤流。我找不到任何东西，但我的retList似乎只是由输入组成，而不是输入的过滤版本。

以下是给我的指示：

//要生成一个整数流，并将其设置为每个谓词p的输入，请将此流变量设置为对流应用过滤器（p）的结果。完成for-each循环后，像我们在前面的问题中所做的那样，将结果流收集到一个列表中，返回结果列表

这是我目前拥有的：

public static List<Integer> matchAll(Stream<Integer> input,  Predicate<Integer>... conditions) { 
    Stream<Integer> stream = input;
    Stream.of(conditions).peek(p -> stream.filter(p));

    List<Integer> retList = stream.collect(Collectors.toList());

    return retList;
}

这就是它的测试方式：

public static void main(String[] args) {
    Stream<Integer> stream = Stream.of(5,7,9,11,13,14,21,28,35,42,49,56,63,70,71);
    Predicate<Integer> p0 = n -> n > 10;
    Predicate<Integer> p1 = n -> n % 2 != 0;
    Predicate<Integer> p2 = n -> isPrime(n);
    System.out.println(Matcher.matchAll(stream, p0, p1, p2));
    // should get [11, 13, 71] 
}

但我实际得到的是[5,7,9,11,13,14,21,28,35,42,49,56,63,70,71]，输入。

Answer 1

在当前的实现中，您没有将过滤的“结果”存储在任何地方。filter方法不会修改原始流，原始流是不可变的，但会返回一个仅包含原始流中匹配值的新流。

实现这一点的一种方法是循环遍历您的条件，用包含应用过滤的新流替换以前的流：

public static List<Integer> matchAll(Stream<Integer> input,  Predicate<Integer>... conditions) { 
    Stream<Integer> stream = input;
    for (Predicate<Integer> condition : conditions) {
       stream = stream.filter(condition);
    }
    return stream.collect(Collectors.toList());
}

Answer 2

您只需在您的matchAll方法中创建一个复合谓词，并使用它过滤输入流，如下所示：

public static List<Integer> matchAll(Stream<Integer> input, Predicate<Integer>... conditions) {
    Predicate<Integer> compositePredicate =
        Arrays.stream(conditions).reduce(Predicate::and).orElse(p -> true); // or else filter in all
    return input.filter(compositePredicate).collect(Collectors.toList());
}

根据霍尔格的建议，您也可以使用：

return Arrays.stream(conditions)
             .reduce(Predicate::and)
             .map(input::filter) // Optional.map here
             .orElse(input)
             .collect(Collectors.toList()); // terminal operation

Answer 3

试试吧

public static List<Integer> matchAll(List<Integer> input, Predicate<Integer>... conditions) {
    Stream<Integer> streams = input.stream();
    for (Predicate<Integer> predicate : conditions) {
        streams = streams.filter(predicate);
    }
    return streams.collect(Collectors.toList());
}

public static void main(String[] args) {
    List<Integer> list = Arrays.asList(5, 7, 9, 11, 13, 14, 21, 28, 35, 42, 49, 56, 63, 70, 71);
    Predicate<Integer> p0 = n -> n > 10;
    Predicate<Integer> p1 = n -> n % 2 != 0;
    Predicate<Integer> p2 = n -> isPrime(n);
    System.out.println(matchAll(list, p0, p1, p2)); // [11, 13, 71]
}

我在这里看到：https://stackoverflow.com/a/51187234/10910098