reactor.core.publisher.Flux#contextCapture 示例

`Flux#contextCapture`是Reactor（Retrofit 2.x版本的事件驱动反应式库）中的一个方法，主要用于在异步流处理中捕获并保存当前的上下文信息。这个方法通常用于需要在操作链中传递请求或响应相关信息的情况下，比如在HTTP请求中保持认证信息、事务标识等。

示例：

// 创建一个Flux源，它会生成一些数据
Mono<String> initialRequest = Flux.just("Hello");

// 使用contextCapture获取当前的Context，然后在这个上下文中发起一个新的网络请求
Flux<String> chainedRequest = initialRequest.flatMapMany(
    Mono.fromCallable(() -> {
        // 模拟网络请求，这里我们假设有个API需要携带额外的Context参数
        WebClient client = WebClient.builder().baseUrl("https://example.com").build();
        return client.get()
            .uri("/api/data")
            .retrieve()
            .toEntity(String.class)
            .doOnNext(response -> response.bodyToMono(String.class))
            .contextWrite(Context.of("additionalInfo", "someValue"));
    }));

// 当chainedRequest完成时，返回的结果将会包含初始请求和上下文信息

在这个例子中，`contextWrite`方法将额外的信息添加到了当前的`WebClient`请求上下文中，后续的操作（如处理服务器响应）可以访问到这个信息。