使用if/检查流状态的Java流处理

Question

给定：客户列表（带供应商和代理字段）、字符串代理、字符串供应商。

目标：检查是否有客户支持给定的代理和给定的供应商。

我有一个流需要过滤两次（两个值）。如果在第一次过滤后流是空的，我需要检查它并抛出异常。如果它不是空的，我需要通过第二个过滤器处理它（然后再次检查它是否不是空的）。

如果可能的话，我想避免将流收集到列表中（我不能使用任何匹配或计数方法，因为它们是终端）

目前我的代码看起来像：

void checkAgencySupplierMapping(String agency, String supplier) {
   List<Customers> customersFilteredByAgency = allCustomers.stream()
             .filter(customer -> customer.getAgency().equals(agency))
             .collect(toList());

   if (customersFilteredByAgency.isEmpty()) throw new AgencyNotSupportedException(agency);

   customersFilteredByAgency.stream()
             .filter(customer -> customer.getSupplier().equals(supplier))
             .findFirst().orElseThrow(() -> throw new SupplierNotSupportedException(supplier);
}

在这个例子中，我跳过了一些关于过滤的技术细节（例如，解析供应商到字符串）。

我想实现这样的目标：

void checkAgencySupplierMapping(String agency, String supplier) {
    allCustomers.stream()
       .filter(customer -> customer.getAgency().equals(agency))
       .ifEmpty( () -> throw new AgencyNotSupportedException(agency) )
       .filter( customer -> customer.getSupplier().equals(supplier)
       .ifEmpty( () -> throw new SupplierNotSupportedException(supplier); // or findFirst().orElseThrow...
}

是否有任何Java8功能，可以让我检查我的流状态而不终止它？

Answer 1

下面的代码有点难看，但可以按照您的意愿工作。

首先，我们需要计算有多少代理客户匹配，然后尝试找到第一个供应商匹配。如果没有匹配，则抛出异常，但在这里您将检查原因是否是没有找到代理客户，以便抛出正确的显示。

AtomicInteger countAgencyMatches = new AtomicInteger(0);

allCustomers.stream()
        .filter(customer -> {
            if (customer.getAgency().equals(agency)) {
                countAgencyMatches.incrementAndGet();
                return true;
            }

            return false;
        })
        .filter(customer -> customer.getSupplier().equals(supplier))
        .findFirst()
        .orElseThrow(() -> {
            if (countAgencyMatches.get() == 0) {
                return new AgencyNotSupportedException(agency);
            }

            return new SupplierNotSupportedException(supplier);
        });