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

[BAEL-1449] Combining Publishers (Project Reactor) fix test names

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