我正在嘗試像這樣在 Flux 上重復(fù)訂閱: DirectProcessor<String> stringDirectProcessor = DirectProcessor.create();
stringDirectProcessor
.repeat(3)
.subscribe(item -> System.out.println(item));
stringDirectProcessor.onNext("one");
stringDirectProcessor.onNext("two");
stringDirectProcessor.onNext("three");
stringDirectProcessor.onComplete();我的期望是看到這個輸出:one
two
three
one
two
three
one
two
three
one
two
three但我只得到one
two
three但是,如果我使用Flux.just()而不是DirectProcessor我得到預(yù)期的輸出。怎么了?
Flux.repeat() 不重復(fù)
慕碼人2483693
2023-02-23 10:02:13