java - CompletableFuture 不适用于 thenAccept

Question

Stream<String> stream = Stream.of("hello", "world");
CompletableFuture<Flux<Integer>> future =
        new CompletableFuture<>();
future.supplyAsync(() -> Flux.fromStream(stream))
        .thenApply(flux -> flux.map(s -> s + " processed"))
        .thenAccept(System.out::println);

sleep(1000);

我希望得到一个输出，Hello processed但World processed它返回FluxMapFuseable。上面的代码有什么问题？