Merge pull request #12048 from anuragkumawat/master
JAVA-11182 Fix CombiningPublishersIntegrationTest
This commit is contained in:
commit
b4f8aa675b
|
@ -18,8 +18,8 @@ public class CombiningPublishersIntegrationTest {
|
||||||
@Test
|
@Test
|
||||||
public void givenFluxes_whenMergeDelayErrorIsInvoked_thenMergeDelayError() {
|
public void givenFluxes_whenMergeDelayErrorIsInvoked_thenMergeDelayError() {
|
||||||
Flux<Integer> fluxOfIntegers = Flux.mergeDelayError(1,
|
Flux<Integer> fluxOfIntegers = Flux.mergeDelayError(1,
|
||||||
evenNumbers.delayElements(Duration.ofMillis(2000L)),
|
evenNumbers.delayElements(Duration.ofMillis(500L)),
|
||||||
oddNumbers.delayElements(Duration.ofMillis(1000L)));
|
oddNumbers.delayElements(Duration.ofMillis(300L)));
|
||||||
|
|
||||||
StepVerifier.create(fluxOfIntegers)
|
StepVerifier.create(fluxOfIntegers)
|
||||||
.expectNext(1)
|
.expectNext(1)
|
||||||
|
|
Loading…
Reference in New Issue