如何用opencsv编写Function<Flux<MyObject>，Flux<String>>

Question

如何编写将对象映射到csv字符串的函数？

public Function<Flux<CleanAccessLogLine>, Flux<String>> toCsv() {
    ...
}

Answer 1

只需使用Flux.map函数：https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#map-java.util.function.Function-

public Function<Flux<CleanAccessLogLine>, Flux<String>> toCsv() {
  return input -> input.map(line -> toCsv(line));
}

String toCsv(CleanAccessLogLine line) {
  // logic that converts the CleanAccessLogLine into a CSV String
}