added .gitignore

.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/

src/test/java/com/mikeruoft/reactor/SimpliefiedMrExampleWithReactor.java → 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);
                     }
                 );
             });