Spring WebClient:如何将大型byte[]流式传输到文件？

import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpStatus;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.channels.FileChannel;
import java.nio.file.Path;
import java.nio.file.Paths;

public class WebClientFileDownload {

    public static void main(String[] args) {
        String url = "https://example.com/large-file.bin";
        Path filePath = Paths.get("downloaded-file.bin");

        WebClient webClient = WebClient.create();

        Mono<Void> download = webClient.get()
                .uri(url)
                .exchangeToFlux(response -> {
                    if (response.statusCode().equals(HttpStatus.OK)) {
                        return response.bodyToFlux(DataBuffer.class);
                    } else {
                        return Flux.error(new RuntimeException("Failed to download file"));
                    }
                })
                .doOnNext(dataBuffer -> {
                    try (FileOutputStream fos = new FileOutputStream(filePath.toFile());
                         FileChannel channel = fos.getChannel()) {
                        channel.write(dataBuffer.asByteBuffer());
                    } catch (IOException e) {
                        throw new RuntimeException("Failed to write file", e);
                    }
                })
                .doOnError(throwable -> System.err.println("Error during download: " + throwable.getMessage()))
                .then();

        download.block();
    }
}