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

Merge pull request #3697 from felipeazv/master

Browse Source 
[BAEL-1449] Combining Publishers (Project Reactor) fix test names
This commit is contained in:
Carsten Gräf 2018-02-20 12:28:56 +01:00 committed by GitHub
commit 0903c30bab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersTest.java
View File

@ -17,7 +17,7 @@ public class CombiningPublishersTest {
@Test @Test
public void testMerge() { public void givenFluxes_whenMergeIsInvoked_thenMerge() {
Flux<Integer> fluxOfIntegers = Flux.merge( Flux<Integer> fluxOfIntegers = Flux.merge(
evenNumbers, evenNumbers,
oddNumbers); oddNumbers);
@ -33,7 +33,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testMergeWithDelayedElements() { public void givenFluxes_whenMergeWithDelayedElementsIsInvoked_thenMergeWithDelayedElements() {
Flux<Integer> fluxOfIntegers = Flux.merge( Flux<Integer> fluxOfIntegers = Flux.merge(
evenNumbers.delayElements(Duration.ofMillis(500L)), evenNumbers.delayElements(Duration.ofMillis(500L)),
oddNumbers.delayElements(Duration.ofMillis(300L))); oddNumbers.delayElements(Duration.ofMillis(300L)));
@ -49,7 +49,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testConcat() { public void givenFluxes_whenConcatIsInvoked_thenConcat() {
Flux<Integer> fluxOfIntegers = Flux.concat( Flux<Integer> fluxOfIntegers = Flux.concat(
evenNumbers.delayElements(Duration.ofMillis(500L)), evenNumbers.delayElements(Duration.ofMillis(500L)),
oddNumbers.delayElements(Duration.ofMillis(300L))); oddNumbers.delayElements(Duration.ofMillis(300L)));
@ -65,7 +65,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testConcatWith() { public void givenFluxes_whenConcatWithIsInvoked_thenConcatWith() {
Flux<Integer> fluxOfIntegers = evenNumbers Flux<Integer> fluxOfIntegers = evenNumbers
.concatWith(oddNumbers); .concatWith(oddNumbers);
@ -80,7 +80,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testCombineLatest() { public void givenFluxes_whenCombineLatestIsInvoked_thenCombineLatest() {
Flux<Integer> fluxOfIntegers = Flux.combineLatest( Flux<Integer> fluxOfIntegers = Flux.combineLatest(
evenNumbers, evenNumbers,
oddNumbers, oddNumbers,
@ -96,7 +96,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testCombineLatest1() { public void givenFluxes_whenCombineLatestIsInvoked_thenCombineLatest1() {
StepVerifier.create(Flux.combineLatest(obj -> (int) obj[1], evenNumbers, oddNumbers)) StepVerifier.create(Flux.combineLatest(obj -> (int) obj[1], evenNumbers, oddNumbers))
.expectNext(1) .expectNext(1)
.expectNext(3) .expectNext(3)
@ -105,7 +105,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testMergeSequential() { public void givenFluxes_whenMergeSequentialIsInvoked_thenMergeSequential() {
Flux<Integer> fluxOfIntegers = Flux.mergeSequential( Flux<Integer> fluxOfIntegers = Flux.mergeSequential(
evenNumbers, evenNumbers,
oddNumbers); oddNumbers);
@ -122,7 +122,7 @@ public class CombiningPublishersTest {
@Test @Test
public void testMergeDelayError() { public void givenFluxes_whenMergeDelayErrorIsInvoked_thenMergeDelayError() {
Flux<Integer> fluxOfIntegers = Flux.mergeDelayError(1, Flux<Integer> fluxOfIntegers = Flux.mergeDelayError(1,
evenNumbers.delayElements(Duration.ofMillis(500L)), evenNumbers.delayElements(Duration.ofMillis(500L)),
oddNumbers.delayElements(Duration.ofMillis(300L))); oddNumbers.delayElements(Duration.ofMillis(300L)));
@ -138,7 +138,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testMergeWith() { public void givenFluxes_whenMergeWithIsInvoked_thenMergeWith() {
Flux<Integer> fluxOfIntegers = evenNumbers.mergeWith(oddNumbers); Flux<Integer> fluxOfIntegers = evenNumbers.mergeWith(oddNumbers);
StepVerifier.create(fluxOfIntegers) StepVerifier.create(fluxOfIntegers)
@ -152,7 +152,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testZip() { public void givenFluxes_whenZipIsInvoked_thenZip() {
Flux<Integer> fluxOfIntegers = Flux.zip( Flux<Integer> fluxOfIntegers = Flux.zip(
evenNumbers, evenNumbers,
oddNumbers, oddNumbers,
@ -166,7 +166,7 @@ public class CombiningPublishersTest {
} }
@Test @Test
public void testZipWith() { public void givenFluxes_whenZipWithIsInvoked_thenZipWith() {
Flux<Integer> fluxOfIntegers = evenNumbers Flux<Integer> fluxOfIntegers = evenNumbers
.zipWith(oddNumbers, .zipWith(oddNumbers,
(a, b) -> a * b); (a, b) -> a * b);
@ -177,6 +177,4 @@ public class CombiningPublishersTest {
.expectComplete() .expectComplete()
.verify(); .verify();
} }
} }