他のパブリッシャーとのバッファー - スプリングリアクター

Question

Flux.buffer（Publisher other）がどのように機能するかの例を挙げることはできますが、元のフラックスを複数のリストに分割するために他のパブリッシャーを利用することはできません。

例：

List<String> strings = new ArrayList<>(); 
    strings.add("A"); 
    strings.add("B"); 
    Flux<String> stringFlux = Flux.fromIterable(strings).cache(); 


    for(int i = 0; i < 100; i++) { 
     strings.add(""+i); 
    } 
    List<Integer> integers = new ArrayList<>(2); 
     integers.add(1); 
    integers.add(1); 
    integers.add(1); 

    stringFlux.buffer((a) -> { 
     Flux.fromIterable(integers); 
    }).subscribe(a -> { 
     System.out.println(a); 
    }); 

これはまだ出力として元のリストを出力しますのではなく、それを分割します。

Answer 1

bufferuntil述語は実際には私が探していたものです。