Reactor Flux：如何使用标题解析文件

Question

最近，我开始使用Project Reactor 3.3，但我不知道什么是处理线通量的最佳方法，首先将行作为列名，然后使用这些列名来处理/转换所有其他行。现在我正在这样做：

Flux<String> lines = ....;
Mono<String[]> columns = Mono.from(lines.take(1).map(header -> header.split(";"))); //getting first line
Flux<SomeDto> objectFlux = lines.skip(1) //skip first line
  .flatMapIterable(row -> //iterating over lines
      columns.map(cols -> convert(cols, row)));  //convert line into SomeDto object

这是正确的方法吗？

Answer 1

这是正确的方法吗？

Answer 2

可以做类似的事情