initial commit

Author: syntax-tee

.idea/.gitignore

@@ -0,0 +1,73 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.example</groupId>
+    <artifactId>java-reactive</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+
+
+    <dependencies>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-core</artifactId>
+        </dependency>
+        <!-- test data -->
+        <dependency>
+            <groupId>com.github.javafaker</groupId>
+            <artifactId>javafaker</artifactId>
+            <version>1.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.16</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>5.4.2</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>io.projectreactor</groupId>
+                <artifactId>reactor-bom</artifactId>
+                <version>2020.0.2</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.0</version>
+                <configuration>
+                    <release>11</release>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+    <properties>
+        <maven.compiler.source>11</maven.compiler.source>
+        <maven.compiler.target>11</maven.compiler.target>
+    </properties>
+
+</project>

.idea/compiler.xml

@@ -0,0 +1,12 @@
+package chap1;
+
+import com.github.javafaker.Faker;
+
+public class FakerDemo {
+
+    public static void main(String[] args) {
+         for(int i =0; i < 10; i++){
+             System.out.println(Faker.instance().name().fullName());
+         }
+    }
+}

.idea/jarRepositories.xml

@@ -0,0 +1,20 @@
+package chap1;
+
+import java.util.stream.Stream;
+
+public class Lec01Stream {
+    public static void main(String[] args) {
+        Stream<Integer> stream = Stream.of(1).map( i->{
+            try {
+                Thread.sleep(1000);
+
+            }catch (InterruptedException e){
+                e.printStackTrace();
+            }
+            return  i * 2;
+        });
+        stream.forEach(System.out::println);
+
+
+    }
+}

.idea/misc.xml

@@ -0,0 +1,25 @@
+package chap1;
+
+import reactor.core.publisher.Mono;
+import utility.Util;
+
+public class Lec03MonoSubscribe {
+
+    public static void main(String[] args) {
+        //publisher
+        Mono<Integer> mono = Mono.just("ball").map(String::length);
+
+        //1
+        mono.subscribe();
+
+        //2 subscriber
+        mono.subscribe(System.out::println,
+                err -> System.out.println(err.getMessage()),
+                () -> System.out.println("Completed"));
+
+        //3 neat with Uitility
+        mono.subscribe(Util.onNext(),
+                err -> Util.onError(),
+                () -> Util.onComplete());
+    }
+}

.idea/uiDesigner.xml

@@ -0,0 +1,24 @@
+package chap1;
+
+import reactor.core.publisher.Mono;
+import utility.Util;
+
+public class Lec04MonoEmptyOrError {
+
+    public static void main(String[] args) {
+        userRepository(2).subscribe(
+                Util.onNext(),
+                Util.onError(),
+                Util.onComplete()
+        );
+    }
+
+    public static Mono<String> userRepository(int userId) {
+        if (userId == 1) {
+            return Mono.just(Util.faker().name().firstName());
+        } else if (userId == 2) {
+            return Mono.empty();
+        } else
+            return Mono.error(new RuntimeException("Not in the allowed range"));
+    }
+}

.idea/vcs.xml

@@ -0,0 +1,34 @@
+package chap1;
+
+import reactor.core.publisher.Mono;
+import utility.Util;
+
+import java.util.concurrent.Callable;
+import java.util.function.Supplier;
+
+public class Lec05MonoFromSupplier {
+
+    public static void main(String[] args) {
+        //use just only when you have the data only
+//        Mono<String> mono = Mono.just(getName());
+
+        Supplier<String> stringSupplier = () -> getName();
+        Mono<String> mono = Mono.fromSupplier(stringSupplier);
+        mono.subscribe(
+                Util.onNext()
+        );
+
+        Callable<String> stringCallable = () -> getName();
+        Mono<String> monoCallable = Mono.fromCallable(stringCallable);
+        monoCallable.subscribe(
+                Util.onNext()
+        );
+
+    }
+
+    private static String getName() {
+        System.out.println("Generating name..");
+        return Util.faker().name().fullName();
+    }
+}
+