我正在嘗試使用 Reactor 的 Flux 并行處理多個(gè)文件。主要工作負(fù)載發(fā)生在對(duì) Flux 的調(diào)用中flatMap，然后對(duì) Flux 進(jìn)行轉(zhuǎn)換和過濾。每當(dāng)我嘗試訂閱生成的 Flux 時(shí)，主線程都會(huì)在收到任何值之前退出。Flux.fromStream(Files.list(Paths.get("directory"))    .flatMap(path -> {         return Flux.create(sink -> {            try (                RandomAccessFile file = new RandomAccessFile(new File(path), "r");                FileChannel fileChannel = file.getChannel()            ) {                // Process file into tokens                sink.next(new Token(".."));            } catch (IOException e) {                sink.error(e);            } finally {                sink.complete();            }        }).subscribeOn(Schedulers.boundedElastic());    })    .map(token -> /* Transform tokens */)    .filter(token -> /* Filter tokens*/)    .subscribe(token -> /* Store tokens in list */)我希望在列表中找到處理管道的輸出，但程序立即退出。首先我想知道我是否正確使用 Flux 類，其次我如何等待訂閱調(diào)用完成？