我正在嘗試像這樣在 Flux 上重復訂閱：    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我得到預期的輸出。怎么了？