如何使用<MyObject>opencsv编写函数<Flux，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
}