refactoring folders; added Java 9 examples

Author: wesleyegberto

java-8/pom.xml

@@ -2,7 +2,7 @@
          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>com.github.wesleyegberto</groupId>
-    <artifactId>java-new-features</artifactId>
+    <artifactId>java-8-new-features</artifactId>
     <version>1.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 

java-9/modules/README.md renamed to java-9/README.md

@@ -0,0 +1,17 @@
+rm -rf target
+
+CLASSES_DIR="target/classes"
+JAR_DIR="target/jars"
+
+mkdir -p $CLASSES_DIR
+mkdir -p $JAR_DIR
+
+$JAVA9_HOME/bin/javac -p jdk.incubator.httpclient -d $CLASSES_DIR --module-version 1.0 `find src/main/java -name *.java`
+
+	# --main-class com.github.wesleyegberto.httpclient.HttpClientTest \
+$JAVA9_HOME/bin/jar -c -f $JAR_DIR/http-client-test.jar \
+    --main-class com.github.wesleyegberto.collections.CollectionsTest \
+	-C $CLASSES_DIR .
+
+
+$JAVA9_HOME/bin/java -p $JAR_DIR -m J9NewFeatures

java-9/modules/simple_deps/build_bundle.sh

@@ -0,0 +1,21 @@
+<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>com.github.wesleyegberto</groupId>
+    <artifactId>java-9-new-features</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <dependencies>
+    </dependencies>
+
+    <build>
+        <finalName>java-9-new-features</finalName>
+    </build>
+
+    <properties>
+        <maven.compiler.source>9</maven.compiler.source>
+        <maven.compiler.target>9</maven.compiler.target>
+        <failOnMissingWebXml>false</failOnMissingWebXml>
+    </properties>
+</project>

java-9/modules/simple_deps/build_modules.sh

@@ -0,0 +1,27 @@
+package com.github.wesleyegberto.collections;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+public class CollectionsTest {
+	public static void main(String[] args) {
+		List.of("First", "Second", "Third")
+			.forEach(System.out::println);
+		
+		Set.of(1, 2, 3, 4, 5)
+			.forEach(System.out::println);
+		
+		Map.of("K1", "V1", "K2", "V2", "K3", "V3", "K4", "V4", "K5", "V5")
+			.forEach((key, value) -> System.out.println(key + " -> " + value));
+		
+		Map.ofEntries(
+				Map.entry("K1", "V1"),
+				Map.entry("K2", "V2"),
+				Map.entry("K3", "V3"),
+				Map.entry("K4", "V4"),
+				Map.entry("K5", "V5")
+			)
+			.forEach((key, value) -> System.out.println(key + " -> " + value));
+	}
+}

java-9/modules/simple_deps/run_bundle.sh

@@ -0,0 +1,33 @@
+package com.github.wesleyegberto.httpclient;
+
+import java.io.IOException;
+import java.net.URI;
+import jdk.incubator.http.*;
+
+public class HttpClientTest {
+	public static void main(String[] args) throws IOException, InterruptedException {
+		HttpRequest request = HttpRequest.newBuilder()
+			.uri(URI.create("http://httpbin.org/uuid"))
+			.GET()
+			.build();
+		
+		String syncResponse = HttpClient.newHttpClient()
+			.send(request, HttpResponse.BodyHandler.asString())
+			.body();
+		
+		System.out.println("Sync response: " + syncResponse);
+		
+		HttpClient.newHttpClient()
+		.sendAsync(request, HttpResponse.BodyHandler.asString())
+		.thenApply(HttpResponse::body)
+		.thenAccept(response -> System.out.println("Async response: " + response));
+		
+
+			/*
+		    .responseAsync() // CompletableFuture
+		    .thenAccept(httpResponse ->
+		        System.out.println(httpResponse.body(HttpResponse.asString()))
+		    );*/
+	  Thread.sleep(5000);
+	}
+}

java-9/modules/simple_deps/run_module_calculator.sh

@@ -0,0 +1,24 @@
+package com.github.wesleyegberto.processapi;
+
+import java.io.IOException;
+
+public class ProcessTest {
+	public static void main(String[] args) throws IOException, InterruptedException {
+		ProcessHandle process = ProcessHandle.current();
+		System.out.println("Main pid: " + process.pid());
+		System.out.println("Main user: " + process.info().user().orElse("Unknown"));
+		
+		Process sleepy = Runtime.getRuntime().exec("sleep 60s");
+		System.out.println("Sleepy pid: " + sleepy.pid());
+		
+		System.out.println("Destroying sleepy");
+		sleepy.onExit()
+			.thenRun(() -> {
+				System.out.println("Alive: " + sleepy.isAlive());
+				System.out.println("Exit code: " + sleepy.exitValue());
+			});
+		sleepy.destroy();
+		
+		Thread.sleep(5000);
+	}
+}

java-9/modules/simple_deps/show_deps.sh

@@ -0,0 +1,42 @@
+package com.github.wesleyegberto.reactive;
+
+import java.util.concurrent.Flow.Subscriber;
+import java.util.concurrent.Flow.Subscription;
+import java.util.concurrent.SubmissionPublisher;
+import java.util.stream.IntStream;
+
+public class FlowTest {
+	public static void main(String[] args) {
+		try (SubmissionPublisher<String> publisher = new SubmissionPublisher<>()) {
+			publisher.subscribe(new MySubscriber());
+
+			IntStream.range(0, 15)
+				.mapToObj(String::valueOf)
+				.forEach(publisher::submit);
+		}
+	}
+}
+
+class MySubscriber implements Subscriber<String> {
+	@Override
+	public void onComplete() {
+		System.out.println("Completed");
+	}
+
+	@Override
+	public void onError(Throwable err) {
+		System.out.println("Error: " + err.getMessage());
+	}
+
+	@Override
+	public void onNext(String item) {
+		System.out.println("Next: " + item);
+	}
+
+	@Override
+	public void onSubscribe(Subscription subscription) {
+		System.out.println("Subscribed, requesting 10 items...");
+		subscription.request(10);
+	}
+
+}

java-9/others-features/build_run.sh

@@ -0,0 +1,3 @@
+module J9NewFeatures {
+	requires jdk.incubator.httpclient;
+}