Combining Publishers (Project Reactor) fix test names
@@ -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();
}
-
-
}
