From 52f79c0b8f69c90634cac5a88bf6c57677866bba Mon Sep 17 00:00:00 2001
From: Gustavo Martin Morcuende <gu.martinm@gmail.com>
Date: Thu, 8 Dec 2016 23:19:15 +0100
Subject: [PATCH] RxJava, using method reference instead of lambdas
---
.../rxjava/tests/service/impl/AsyncHTTPClient.java | 34 ++++++++++++++--------
.../rxjava/tests/service/impl/FlatMapTestImpl.java | 9 +++++-
2 files changed, 30 insertions(+), 13 deletions(-)
diff --git a/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/AsyncHTTPClient.java b/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/AsyncHTTPClient.java
index 0a0f11e..252a7d5 100644
--- a/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/AsyncHTTPClient.java
+++ b/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/AsyncHTTPClient.java
@@ -12,18 +12,28 @@ public class AsyncHTTPClient {
public void getPages() {
getDataAsync("https://github.com/gumartinm")
- // fancy Java way of using lambdas.
- .subscribe(System.out::println); //The subscribe method starts to run the code implemented in getDataSync
- //subscribeOn just declares who is going to run my code (a pool of threads)
- //subscribe is the guy who starts to run my code!!!
- //JavaScript does the same with Promises but in a cleaner way (IMHO), it does not
- //need a subscribe method for starting the machinery (the machinery is underneath
- //implemented by the Web Browser with its asynchronous callbacks)
- getDataAsync("http://www.google.de").subscribe(page -> {
- System.out.println("Another way, no so cool (with lambdas)");
- System.out.println(Thread.currentThread().getName());
- System.out.println(page);
- });
+ // fancy Java way of using lambdas. Called method reference :)
+ .subscribe(System.out::println, //The subscribe method starts to run the code implemented in getDataSync
+ Throwable::printStackTrace);//subscribeOn just declares who is going to run my code (a pool of threads)
+ //subscribe is the guy who starts to run my code!!!
+ //JavaScript does the same with Promises but in a cleaner way (IMHO), it does not
+ //need a subscribe method for starting the machinery (the machinery is underneath
+ //implemented by the Web Browser with its asynchronous callbacks)
+
+
+ getDataAsync("http://www.google.de").
+ subscribe(page -> { // It will be called on success :)
+ System.out.println("Another way, no so cool (with lambdas)");
+ System.out.println(Thread.currentThread().getName());
+ System.out.println(page);
+
+ }, exception -> exception.printStackTrace()); // It will be called on error. :)
+
+
+ // The same with method reference :)
+ getDataAsync("http://www.google.es").
+ subscribe(System.out::println, // It will be called on success :)
+ Throwable::printStackTrace); // It will be called on error. :)
System.out.println("AsyncHTTPClient: YOU SEE ME FIRST!!!!");
diff --git a/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/FlatMapTestImpl.java b/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/FlatMapTestImpl.java
index a06bf33..1c6b27d 100644
--- a/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/FlatMapTestImpl.java
+++ b/Allgemeines/RxJava/src/main/java/de/rxjava/tests/service/impl/FlatMapTestImpl.java
@@ -18,7 +18,14 @@ public class FlatMapTestImpl {
.subscribe(word -> { //Unlike JavaScript Promises, we can call many times the same promise without resolving it.
//This stuff would be impossible in JavaScript :)
System.out.println(word);
- });
+ }, exception -> exception.printStackTrace());
+
+
+ // The same with method references!!!
+ getWordsAsync()
+ .flatMap(Observable::from)
+ .subscribe(System.out::println, Throwable::printStackTrace);
+
System.out.println("FlatMapTestImpl: YOU SEE ME FIRST!!!!");
--
2.1.4