diff --git a/reactor-core/pom.xml b/reactor-core/pom.xml
index c9917d14df..317cbde6e2 100644
--- a/reactor-core/pom.xml
+++ b/reactor-core/pom.xml
@@ -34,7 +34,7 @@
- 3.2.6.RELEASE
+ 3.3.9.RELEASE
3.6.1
diff --git a/reactor-core/src/test/java/com/baeldung/reactor/ReactorIntegrationTest.java b/reactor-core/src/test/java/com/baeldung/reactor/introduction/ReactorIntegrationTest.java
similarity index 91%
rename from reactor-core/src/test/java/com/baeldung/reactor/ReactorIntegrationTest.java
rename to reactor-core/src/test/java/com/baeldung/reactor/introduction/ReactorIntegrationTest.java
index e3060b8e02..a1acffac91 100644
--- a/reactor-core/src/test/java/com/baeldung/reactor/ReactorIntegrationTest.java
+++ b/reactor-core/src/test/java/com/baeldung/reactor/introduction/ReactorIntegrationTest.java
@@ -1,4 +1,4 @@
-package com.baeldung.reactor;
+package com.baeldung.reactor.introduction;
import org.junit.Test;
import org.reactivestreams.Subscriber;
@@ -15,7 +15,7 @@ import static org.assertj.core.api.Assertions.assertThat;
public class ReactorIntegrationTest {
@Test
- public void givenFlux_whenSubscribing_thenStream() throws InterruptedException {
+ public void givenFlux_whenSubscribing_thenStream() {
List elements = new ArrayList<>();
@@ -48,14 +48,12 @@ public class ReactorIntegrationTest {
}
@Test
- public void givenFlux_whenApplyingBackPressure_thenPushElementsInBatches() throws InterruptedException {
+ public void givenFlux_whenApplyingBackPressure_thenPushElementsInBatches() {
List elements = new ArrayList<>();
Flux.just(1, 2, 3, 4)
.log()
- .map(i -> i * 2)
- .onBackpressureBuffer()
.subscribe(new Subscriber() {
private Subscription s;
int onNextAmount;
@@ -81,11 +79,10 @@ public class ReactorIntegrationTest {
@Override
public void onComplete() {
- int ham = 2;
}
});
- assertThat(elements).containsExactly(2, 4, 6, 8);
+ assertThat(elements).containsExactly(1, 2, 3, 4);
}
@Test