diff --git a/reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersTest.java b/reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersTest.java index 9d5d094875..81dfda3bb3 100644 --- a/reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersTest.java +++ b/reactor-core/src/test/java/com/baeldung/reactor/core/CombiningPublishersTest.java @@ -17,7 +17,7 @@ public class CombiningPublishersTest { @Test - public void testMerge() { + public void givenFluxes_whenMergeIsInvoked_thenMerge() { Flux fluxOfIntegers = Flux.merge( evenNumbers, oddNumbers); @@ -33,7 +33,7 @@ public class CombiningPublishersTest { } @Test - public void testMergeWithDelayedElements() { + public void givenFluxes_whenMergeWithDelayedElementsIsInvoked_thenMergeWithDelayedElements() { Flux 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 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 fluxOfIntegers = evenNumbers .concatWith(oddNumbers); @@ -80,7 +80,7 @@ public class CombiningPublishersTest { } @Test - public void testCombineLatest() { + public void givenFluxes_whenCombineLatestIsInvoked_thenCombineLatest() { Flux 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 fluxOfIntegers = Flux.mergeSequential( evenNumbers, oddNumbers); @@ -122,7 +122,7 @@ public class CombiningPublishersTest { @Test - public void testMergeDelayError() { + public void givenFluxes_whenMergeDelayErrorIsInvoked_thenMergeDelayError() { Flux 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 fluxOfIntegers = evenNumbers.mergeWith(oddNumbers); StepVerifier.create(fluxOfIntegers) @@ -152,7 +152,7 @@ public class CombiningPublishersTest { } @Test - public void testZip() { + public void givenFluxes_whenZipIsInvoked_thenZip() { Flux fluxOfIntegers = Flux.zip( evenNumbers, oddNumbers, @@ -166,7 +166,7 @@ public class CombiningPublishersTest { } @Test - public void testZipWith() { + public void givenFluxes_whenZipWithIsInvoked_thenZipWith() { Flux fluxOfIntegers = evenNumbers .zipWith(oddNumbers, (a, b) -> a * b); @@ -177,6 +177,4 @@ public class CombiningPublishersTest { .expectComplete() .verify(); } - - }