我有一个整数流，我想找到总和等于另一个数字的两个数字。所以我想出了以下解决方案：
BiPredicate<Integer, Integer> p = (price1, price2) -> price1.intValue() + price2.intValue() == moneyQty;
flavoursPrices.filter(p);
但是过滤器方法没有收到 BiPredicate。为什么不？有什么替代方法？
【问题讨论】：
标签： java lambda filter functional-programming predicate
您仍然可以使用 Bipredicate。 filter-method 需要的参数是 Predicate，所以这里是一个如何使用这个 BiPredicate 的例子：
BiPredicate<Integer, Integer> p = (price1, price2) -> price1.intValue() + price2.intValue() == moneyQty;
flavoursPrices.stream().filter(el->p.test(el.price1,el.price2));
在这个例子中，flavorsPrices 必须是一个列表。
我们正在使用的 lambda：
el->p.test(el.price1,el.price2)
正在替换匿名内部类声明以从 BiPredicate 中创建新的 Predicate：
Predicate<Integer> arg =new Predicate<Integer>() {
@Override
public boolean test(Element el) {
return p.test(el.price1,el.price2);
}
};
所以为了过滤流，我们为来自流的每个元素创建一个新的谓词，然后我们使用这个谓词作为参数来使用它的测试方法。这样做的最大好处是，我们不必预先创建大量的 Predicates，但我们可以传递 lambda 函数中的每个元素并获取它的属性。
【讨论】：
因为filter 不是这样工作的，它一次只过滤一个集合。对于您的任务，您需要 Python 的 itertools.product 之类的东西；这可以使用flatMap 来实现。在 Scala 中，这看起来很短：
prices.flatMap(p1 =>
prices.flatMap(p2 =>
if (p1 + p2 == 5) List((p1, p2)) else List()))
如果你想用（原生）Java 来做，会出现这样的结果：
import java.util.*;
import java.util.stream.*;
public class Main {
public static void main(String[] args) {
List<Integer> prices = Arrays.asList(1,2,3,4,5,6,7,8,9);
List<List<Integer>> result = prices.stream().flatMap(p1 ->
prices.stream().flatMap(p2 ->
p1 + p2 == 5 ? Stream.of(Arrays.asList(p1, p2)) : Stream.empty()
)
).collect(Collectors.toList());
System.out.println(result);
}
}
...打印[[1, 4], [2, 3], [3, 2], [4, 1]]。但我不会在现实中使用它；）至少，拥有一个元组类会很好。
值得注意的是flatMap是最强大的功能之一；几乎所有的流转换（过滤器、映射、笛卡尔积、展平）都可以使用它来实现。其余部分（如 zip）几乎总是折叠/缩小（或者，很少是展开）。
【讨论】：
p1 + p2 == 5 ? Stream.of(Arrays.asList(p1, p2)) : Stream.empty()，从而得到List<List<Integer>>。很好的答案！
for { p1 <- prices; p2 <- prices; if p1 + p2 == 5 } yield (p1, p2)。
Predicate != BiPredicate
Stream#filter 接受 Predicate (Object -> boolean) 将一次处理每个元素。
您可能需要查看StreamEx 库以获取解决方案。
它具有将流中连续元素配对的方法。
【讨论】：
flatMap: prices.flatMap(p1 => prices.flatMap(p2 => if (p1 + p2 == 5) List((p1, p2)) else List()))（在 Scala 中，但应该易于翻译）。
如何使用StreamEx library 实施您的解决方案：
StreamEx.ofPairs(prices, (p1, p2) -> p1 + p2 == 5 ? StreamEx.of(p1, p2) : StreamEx.empty())
.flatMap(Function.identity())
.forEach(price -> System.out.println(price));
您可能还想创建自己的类来封装这些对。
【讨论】：