在进行通量处理时，如何正确抛出异常？

Question

我拥有的现有代码：

private Flux<Integer> testGetFluxTestData() {
    return Flux.just(new TestData(1), new TestData(2))
            .collectList()
            .map(list -> list.stream()
                    .map(TestData::getId)
                    .collect(Collectors.toList()))
            .flatMapMany(Flux::fromIterable);
}

我想丰富现有代码，并在收到一些不允许的数据时引发异常，我做了以下更改：

    private Flux<Integer> testGetFluxTestData2() {
        return Flux.just(new TestData(1), new TestData(2))
                .collectList()
                .map(list -> {
                    return !list.contains(new TestData(1)) ?
                            list.stream()
                                    .map(TestData::getId)
                                    .collect(Collectors.toList()) :
                            Flux.error(new IllegalTestDataException("illegal test data 1"));
                })
                .flatMapMany(Flux::fromIterable);
    }

但由于以下原因，我的实现甚至不可编译：

Flux.error(new IllegalTestDataException("illegal test data 1"));

您能为我的特定场景提供建议吗？

Answer 1

您正在尝试从列表中map

（旁注：即使您在一个平面映射中，它也不起作用，因为此时由于集合列表，您在一个API中，所以平面映射期望函数得到一个结果）。

请注意，map操作符捕捉lambda中的异常，并将其转换为一个错误信号，因此从技术上讲，您可以替换通量。错误，抛出。

否则，您需要将映射转化为平面映射和通量。错误变成单声道。错误，原因如上所述。