diff --git a/pom.xml b/pom.xml
index 9d6c5931e3..014e4016c5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -94,6 +94,7 @@
querydsl
+ reactor-core
redis
rest-assured
rest-testing
diff --git a/reactor-core/pom.xml b/reactor-core/pom.xml
new file mode 100644
index 0000000000..2be8892983
--- /dev/null
+++ b/reactor-core/pom.xml
@@ -0,0 +1,59 @@
+
+ 4.0.0
+
+ org.baeldung
+ reactor-core
+ 0.0.1-SNAPSHOT
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 1.8
+ 1.8
+
+
+
+
+
+
+
+
+ io.projectreactor
+ reactor-core
+ ${reactor-core.version}
+
+
+
+ junit
+ junit
+ ${junit.version}
+ test
+
+
+
+ org.assertj
+ assertj-core
+ ${assertj.version}
+ test
+
+
+
+ ch.qos.logback
+ logback-classic
+ ${logback.version}
+
+
+
+
+
+ 3.0.4.RELEASE
+ 4.12
+ 3.6.1
+ 1.1.3
+
+
+
diff --git a/reactor-core/src/test/java/com/baeldung/reactor/ReactorTest.java b/reactor-core/src/test/java/com/baeldung/reactor/ReactorTest.java
new file mode 100644
index 0000000000..46b774c30e
--- /dev/null
+++ b/reactor-core/src/test/java/com/baeldung/reactor/ReactorTest.java
@@ -0,0 +1,122 @@
+package com.baeldung.reactor;
+
+import org.junit.Test;
+import org.reactivestreams.Subscriber;
+import org.reactivestreams.Subscription;
+import reactor.core.publisher.ConnectableFlux;
+import reactor.core.publisher.Flux;
+import reactor.core.scheduler.Schedulers;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class ReactorTest {
+
+ @Test
+ public void givenFlux_whenSubscribing_thenStream() throws InterruptedException {
+
+ List elements = new ArrayList<>();
+
+ Flux.just(1, 2, 3, 4)
+ .log()
+ .map(i -> {
+ System.out.println(i + ":" + Thread.currentThread());
+ return i * 2;
+ })
+ .subscribe(elements::add);
+
+ assertThat(elements).containsExactly(2, 4, 6, 8);
+ }
+
+ @Test
+ public void givenFlux_whenZipping_thenCombine() {
+ List elements = new ArrayList<>();
+
+ Flux.just(1, 2, 3, 4)
+ .log()
+ .map(i -> i * 2)
+ .zipWith(Flux.range(0, Integer.MAX_VALUE).log(), (two, one) -> String.format("First Flux: %d, Second Flux: %d", one, two))
+ .subscribe(elements::add);
+
+ assertThat(elements).containsExactly(
+ "First Flux: 0, Second Flux: 2",
+ "First Flux: 1, Second Flux: 4",
+ "First Flux: 2, Second Flux: 6",
+ "First Flux: 3, Second Flux: 8");
+ }
+
+ @Test
+ public void givenFlux_whenApplyingBackPressure_thenPushElementsInBatches() throws InterruptedException {
+
+ List elements = new ArrayList<>();
+
+ Flux.just(1, 2, 3, 4)
+ .log()
+ .map(i -> i * 2)
+ .onBackpressureBuffer()
+ .subscribe(new Subscriber() {
+ private Subscription s;
+ int onNextAmount;
+
+ @Override
+ public void onSubscribe(final Subscription s) {
+ this.s = s;
+ s.request(2);
+ }
+
+ @Override
+ public void onNext(final Integer integer) {
+ elements.add(integer);
+ onNextAmount++;
+ if (onNextAmount % 2 == 0) {
+ s.request(2);
+ }
+ }
+
+ @Override
+ public void onError(final Throwable t) {
+ }
+
+ @Override
+ public void onComplete() {
+ int ham = 2;
+ }
+ });
+
+ assertThat(elements).containsExactly(2, 4, 6, 8);
+ }
+
+ @Test
+ public void givenFlux_whenInParallel_thenSubscribeInDifferentThreads() throws InterruptedException {
+ List threadNames = new ArrayList<>();
+
+ Flux.just(1, 2, 3, 4)
+ .log()
+ .map(i -> Thread.currentThread().getName())
+ .subscribeOn(Schedulers.parallel())
+ .subscribe(threadNames::add);
+
+ Thread.sleep(1000);
+
+ assertThat(threadNames).containsExactly("parallel-1", "parallel-1", "parallel-1", "parallel-1");
+ }
+
+ @Test
+ public void givenConnectableFlux_thenShouldStream_onConnect() {
+
+ List elements = new ArrayList<>();
+
+ final ConnectableFlux publish = Flux.just(1, 2, 3, 4).publish();
+
+ publish.subscribe(elements::add);
+
+ assertThat(elements).isEmpty();
+
+ publish.connect();
+
+ assertThat(elements).containsExactly(1, 2, 3, 4);
+ }
+
+}