Project Reactor条件行为问题：Mono<Void>致switchIfEmpty始终执行

问题核心在于：processDataFromCache(data)返回的Mono<Void>本身代表无元素的流——它只会发送完成或错误信号，不会发射任何数据。当getDataFromCache()返回有数据的Mono<T>时，经过flatMap转换后，整个流变成Mono<Void>，此时switchIfEmpty会误判该流为空，从而总是执行doSomethingElse()分支。

以下是几种可行的实现方式，可避免switchIfEmpty的误触发：

方案一：缓存结果避免重复调用，通过存在性判断分支 #

先缓存getDataFromCache()的结果，避免重复调用外部缓存；再通过hasElement()判断缓存是否存在，分别执行对应逻辑：

Mono<Void> myMethod() {
    // 缓存缓存查询结果，避免重复调用外部缓存
    Mono<Data> cacheData = getDataFromCache().cache();
    
    return cacheData
            .hasElement()
            .flatMap(exists -> {
                if (exists) {
                    return cacheData.flatMap(this::processDataFromCache);
                } else {
                    return doSomethingElse();
                }
            });
}

方案二：保留元素标记，避免流变为空 #

在处理缓存数据后，返回一个非空元素（比如原数据），让switchIfEmpty识别到流不为空；最后通过then()转换为Mono<Void>：

Mono<Void> myMethod() {
    return getDataFromCache()
            // 处理完缓存数据后，返回原数据作为流的元素，避免流为空
            .flatMap(data -> processDataFromCache(data).then(Mono.just(data)))
            // 只有当缓存确实为空时，才执行else分支
            .switchIfEmpty(doSomethingElse())
            // 最终转换为Mono<Void>
            .then();
}

方案三：使用特殊标记值区分缓存为空的情况 #

如果不想额外保留元素，可通过defaultIfEmpty设置特殊标记值，再分支处理：

Mono<Void> myMethod() {
    // 定义一个不会和业务数据冲突的特殊标记
    final Data EMPTY_MARKER = new Data();
    
    return getDataFromCache()
            // 缓存为空时，返回特殊标记值
            .defaultIfEmpty(EMPTY_MARKER)
            .flatMap(data -> {
                if (data != EMPTY_MARKER) {
                    return processDataFromCache(data);
                } else {
                    return doSomethingElse();
                }
            });
}

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