iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

JAVA-8859

This commit is contained in:
anuragkumawat 2022-04-11 21:53:04 +05:30
parent 4ad546c702
commit 0ad2fa5412
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersIntegrationTest.java
View File

@ -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)