From 12e62f1285e33997af5c45c0b31df097731f7ad2 Mon Sep 17 00:00:00 2001
From: "grinfeld@gmail.com" <grin1946>
Date: Sat, 1 Jul 2017 15:08:36 +0300
Subject: [PATCH] added .gitignore

---
 .gitignore                                    | 20 +++++++++++++++++++
 ...va => SimplifiedMrExampleWithReactor.java} |  6 +++---
 2 files changed, 23 insertions(+), 3 deletions(-)
 create mode 100644 .gitignore
 rename src/test/java/com/mikeruoft/reactor/{SimpliefiedMrExampleWithReactor.java => SimplifiedMrExampleWithReactor.java} (96%)

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..576ad76
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,20 @@
+# Created by .ignore support plugin (hsz.mobi)
+### JetBrains template
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+## File-based project format:
+*.iws
+*.iml
+
+# IntelliJ
+/out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+/.idea/
+**/target/
\ No newline at end of file
diff --git a/src/test/java/com/mikeruoft/reactor/SimpliefiedMrExampleWithReactor.java b/src/test/java/com/mikeruoft/reactor/SimplifiedMrExampleWithReactor.java
similarity index 96%
rename from src/test/java/com/mikeruoft/reactor/SimpliefiedMrExampleWithReactor.java
rename to src/test/java/com/mikeruoft/reactor/SimplifiedMrExampleWithReactor.java
index c717407..f5824c5 100644
--- a/src/test/java/com/mikeruoft/reactor/SimpliefiedMrExampleWithReactor.java
+++ b/src/test/java/com/mikeruoft/reactor/SimplifiedMrExampleWithReactor.java
@@ -19,7 +19,7 @@
 /**
  * @author Mikhail Grinfeld
  */
-public class SimpliefiedMrExampleWithReactor {
+public class SimplifiedMrExampleWithReactor {
 
     private static Flux<List<RoutingInfo>> fromAkaDB() {
         return Flux.defer(() -> Flux.just(Arrays.asList(
@@ -63,7 +63,7 @@ public void fluxTest() throws InterruptedException {
                     // create stream of RoutingInfo from list
                     Flux.fromIterable(l)
                     // enrich individual RoutingInfo with additional data
-                    .map(SimpliefiedMrExampleWithReactor::setSerices)
+                    .map(SimplifiedMrExampleWithReactor::setSerices)
                     // grouped by same message id
                     .groupBy(RoutingInfo::getMessageId, Function.identity())
                     .flatMap(groups -> groups.collect(Collectors.toList()))
@@ -90,7 +90,7 @@ public void fluxTest() throws InterruptedException {
                         // assign to this stream thread pool executor to use for parallel execution
                         .subscribeOn(Schedulers.fromExecutor(executor))
                         // here we actually start sending MC
-                        .subscribe(SimpliefiedMrExampleWithReactor::sendMc);
+                        .subscribe(SimplifiedMrExampleWithReactor::sendMc);
                     }
                 );
             });