WebFlux：如何使用takeUntilOther（）方法？

Question

java prettyprint-override">     Mono.just(10)
                .subscribe();

        Flux.range(1, 5)
                .takeUntilOther(Mono.just(10))
                .subscribe(System.out::println);

我不明白为什么。

Answer 1

基里尔，

我建议你参考项目Reactor文档的适当部分。

TakeUntiLother(Publisher other)从中传递值，直到给定的Publisher发出。

Flux.range(1, 5) // produces elements from 1 to 5
        .delayElements(Duration.ofSeconds(1)) // delays emission of each element from above for 1 second
        .takeUntilOther(Mono
                .just(10) // hot publisher. emits one element

                // delays '10' for 3 seconds. meaning that it will only 
                // appears in the original Flux in 3 seconds
                .delayElement(Duration.ofSeconds(3)) 
        )
        .subscribe(System.out::print);