Flux.never 使用说明书

public static <T> Flux<T> never()

Create a Flux that will never signal any data, error or completion signal.

创建一个永远不会发出任何数据、错误或完成信号的 Flux。

Type Parameters:

T - the Subscriber type target

Returns:

a never completing Flux

类型参数：

T - 目标订阅者的类型

返回：

一个永远不会完成的 Flux

never() 是 Flux 类中的一个静态方法，用来创建一个永远不会发出任何信号（包括元素、错误或完成）的 Flux。

这是 Reactor 框架中的一种特殊类型的流，它不会做任何事情，保持 "沉默"。

1. 方法简介

never()：返回一个永远不会发出任何元素、错误或完成信号的 Flux。

2. 参数说明

无参数：这个方法没有参数，因为它只生成一个不做任何事情的 Flux。

3. 返回值

Flux<T>：返回一个类型为 T 的 Flux，但实际上这个 Flux 不会发出任何值、错误或者完成信号。

4. 使用场景

Flux.never() 常用于测试场景或占位符逻辑，以及一些高级的响应式流控制情境。

测试异步操作：有时候你可能想测试某些系统在没有任何数据流或事件发生时的行为，此时可以使用 Flux.never()。
占位符：在需要返回一个 Flux，但不想立即提供实际数据或不想让流结束的情况下，可以用 never() 方法来生成一个不活跃的流。
保持连接活跃：在某些应用中，可能需要保持某种连接或订阅存在但不发出数据，比如当你希望流存在但暂时不发送任何事件时。

5. 示例代码

javaimport reactor.core.publisher.Flux;public class FluxNeverExample {public static void main(String[] args) {// 创建一个永远不发出任何事件的 FluxFlux<String> neverFlux = Flux.never();// 订阅并观察不会有任何输出neverFlux.subscribe(data -> System.out.println("Received data: " + data),error -> System.out.println("Received error: " + error),() -> System.out.println("Stream completed"));// 为了防止程序立即退出try {Thread.sleep(5000);  // 保持程序运行一段时间，观察没有任何输出} catch (InterruptedException e) {e.printStackTrace();}}
}

在这个例子中，Flux.never() 不会输出任何结果，因此在订阅后你不会看到任何数据、错误或完成信号的输出。程序会一直保持运行，直到手动终止。

6. 特性与优势

无信号：Flux.never() 不发出任何元素、错误或完成信号，这使得它在需要无操作时非常实用。
用于占位符：可以在需要返回 Flux 但又不希望立即提供数据的场景下使用它作为占位符。
异步处理模拟：可以用作测试代码或模拟某种异步处理没有开始的场景，观察其他逻辑是否能够正确处理这种 "空闲" 情况。

7. 注意事项

无输出：由于 Flux.never() 不会发出任何信号，因此订阅它的流将一直处于等待状态，这在一些场景下可能会导致阻塞或资源被持续占用。
与其他流结合：Flux.never() 通常是作为其他 Flux 或流操作中的辅助工具。例如，可以与 timeout 等操作符结合使用，以模拟某种超时机制。

8. 高级用法

你可以通过与 timeout 或 switchIfEmpty 等操作符结合来进一步利用 Flux.never()，实现一些复杂的流逻辑控制。

javaFlux<String> fallback = Flux.just("Fallback Data");// 使用 never() 并在超时后切换到备用 Flux
Flux<String> result = Flux.never().timeout(Duration.ofSeconds(3)).onErrorResume(throwable -> fallback);result.subscribe(System.out::println);

在这个例子中，Flux.never() 会在 3 秒后超时，并切换到备用 Flux，从而发出 "Fallback Data"。