Java 8 流中的 IfPresentOrElse 场景

Question

我有一个使用嵌套流的场景。 PFB 代码：

    list.parallelStream()
        .filter(item -> productList.parallelStream()
            .anyMatch(product -> product.getProductName().equals(item.getProductName())
                 && item.getQuantity() <= product.getAvailableQuantity()));

在这里，我试图根据 productnames 进行过滤，它工作得非常好，但我需要在任何匹配中添加一个 else 条件。如果没有找到匹配项，我需要抛出错误“product not found”。我尝试使用ifPresentOrElse，但它需要Consumer 接口作为返回void 的参数（但在我的情况下它必须返回一个布尔值）。任何帮助表示赞赏。

谢谢。

Answer 1

您可以使用orElseThrow。

orElseThrow(ProductNotFoundException::new)

您不能将orElseThrow() 与anyMatch() 一起使用，因为它返回布尔值。 您可以在filter() 上使用findAny()，这将返回Optional，然后您可以在Optional 上使用orElseThrow() 引发异常。

例如：

 list.parallelStream()
        .filter(item -> productList.parallelStream()
            .anyMatch(product -> product.getProductName().equals(item.getProductName())
                 && item.getQuantity() <= product.getAvailableQuantity()))
        .findAny().orElseThrow(ProductNotFoundException::new);

编辑：

OP 想要在第一个未找到的产品上抛出错误。

        list.parallelStream()
                .filter(item -> {
                    if (productList.parallelStream().anyMatch(product -> product.getProductName().equals(item.getProductName())
                                    && item.getQuantity() <= product.getAvailableQuantity())) {
                        return true;
                    } else {
                        throw new ProductNotFoundException();
                    }
                });

为要执行的流添加一个终端操作。