From d237c52a1f677b0cac7f59ca71bd0fa7a9ff6c95 Mon Sep 17 00:00:00 2001
From: Maiklins <kruemel@quantentunnel.de>
Date: Mon, 31 Aug 2020 19:41:46 +0200
Subject: [PATCH] Java-75 update intro to reactor core (#9953)

* Java-75 Update intro to Reactor Core

* Java-75 Create package for introduction

* Java-75 Update reactor version and align unit test with article

Co-authored-by: mikr <michael.krimgen@ximedes.com>
---
 reactor-core/pom.xml                                  |  2 +-
 .../{ => introduction}/ReactorIntegrationTest.java    | 11 ++++-------
 2 files changed, 5 insertions(+), 8 deletions(-)
 rename reactor-core/src/test/java/com/baeldung/reactor/{ => introduction}/ReactorIntegrationTest.java (91%)

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 @@
     </dependencies>
 
     <properties>
-        <reactor.version>3.2.6.RELEASE</reactor.version>
+        <reactor.version>3.3.9.RELEASE</reactor.version>
         <assertj.version>3.6.1</assertj.version>
     </properties>
 
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<Integer> elements = new ArrayList<>();
 
@@ -48,14 +48,12 @@ public class ReactorIntegrationTest {
     }
 
     @Test
-    public void givenFlux_whenApplyingBackPressure_thenPushElementsInBatches() throws InterruptedException {
+    public void givenFlux_whenApplyingBackPressure_thenPushElementsInBatches() {
 
         List<Integer> elements = new ArrayList<>();
 
         Flux.just(1, 2, 3, 4)
                 .log()
-                .map(i -> i * 2)
-                .onBackpressureBuffer()
                 .subscribe(new Subscriber<Integer>() {
                     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