用于停止数据流的客户端到服务器通信

问：

这是我的场景：

1. 服务器使用 WebFlux 生成无穷无尽的数据和流。
2. 客户端使用 WebClient 开发，在满足某些条件后，客户端希望服务器停止流数据以避免进一步的数据泄露。

输入流：Flux.range（1,1000） customer。
客户端：如果值为 customer 为 7，则客户端不需要任何输入数据。这意味着服务器必须停止流数据。

在客户端，我是这样编码的：

flux.takeUntil(this::processResponse).subscribe();

private boolean processResponse(Customer customer) {
    boolean foundData = false;
    System.out.println(customer.getCustomer());
    if (customer.getCustomer().equals("customer7")) {
        foundData = true;
    }
    return  foundData;
}

我注意到服务器仍在发送数据，即使客户端不再需要它。