java - 将串通量拆分为多个通量

Question

我有一个像这样的字符串 Flux

field1=value1,terminalField=true,field2=value2,field3=value3,terminalField=true

我想根据特定的分隔符分割成更小的字符串

field1=value1、terminalField=true、...

并发射到另一个 Flux 中，最终目标是发射一个累积所有字段的对象，直到 terminalField=true ，以便 Flux 包含

对象(field1=value1，terminalField=true)，对象(field2=value2，field3=value3，terminalField=true)。

我研究过各种运算符，但我对 Reactor 很陌生，所以对它的样子有点挣扎。任何帮助将不胜感激。

Answer 1

我认为Flux#flatMapIterable operator这就是您正在寻找的。

用逗号分隔，然后使用 Flux#windowUntil operator将其转换为Flux<Flux<String>> ，每一个内心的地方Flux将是一个键值对流，直到终止键值对。

然后由你决定如何将内部通量转换为对象。您可以使用 Flux#collectMap operator和.map或其他收集/归约运算符。