Flux调用last()遇空序列报错，求正确处理方案

问题根源 #

Flux.last()在订阅的Flux没有产生任何onNext信号时，会抛出NoSuchElementException（也就是你看到的Flux#last() didn't observe any onNext signal错误）。你之前尝试的switchIfEmpty()没生效，大概率是因为加错了位置——它只能处理Flux本身为空的场景，但如果是last()触发的异常，得针对这个异常处理，或者换用不会报错的替代方法。

三种实用解决方案 #

1. 直接捕获异常返回空Mono

最简单的方式是在last()之后用onErrorResume()捕获特定异常，转为空Mono终止链操作：

return apiService.getAll(entry)
    .flatMap(response -> {
        if (response.getId() != null){
            // do some logic
            return Mono.just("some Mono");
        } else {
            return Mono.empty();
        }
    })
    .last()
    // 捕获last()抛出的无元素异常，返回空Mono
    .onErrorResume(NoSuchElementException.class, e -> Mono.empty())
    // more flatMap operators

2. 用lastOrDefault()替代last()

如果允许返回一个默认值（比如null），可以用lastOrDefault()，它在Flux为空时会返回指定的默认值，不会抛出异常：

return apiService.getAll(entry)
    .flatMap(response -> {
        if (response.getId() != null){
            // do some logic
            return Mono.just("some Mono");
        } else {
            return Mono.empty();
        }
    })
    // 为空时返回null，后续操作可判断是否为null再处理
    .lastOrDefault(null)
    // more flatMap operators

3. 先判断是否有元素再执行last()

如果需要明确判断Flux是否有元素再决定后续逻辑，可以先缓存前面的Flux结果，避免重复调用接口，再通过hasElements()分支处理：

// 先缓存处理后的Flux，避免重复订阅调用接口
Flux<String> processedFlux = apiService.getAll(entry)
    .flatMap(response -> {
        if (response.getId() != null){
            // do some logic
            return Mono.just("some Mono");
        } else {
            return Mono.empty();
        }
    })
    .cache();

return processedFlux.hasElements()
    .flatMap(hasElements -> {
        // 有元素才调用last()，否则返回空Mono
        return hasElements ? processedFlux.last() : Mono.empty();
    })
    // more flatMap operators

内容的提问来源于stack exchange，提问作者Lucho82