與其他發行商的緩衝區 - 彈簧反應器

Question

任何人都可以舉例說明Flux.buffer（發佈者其他）如何工作，即時無法利用其他發佈者將原始通量分成多個列表。

例：

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帶謂詞實際上是我在找的東西。