From 597d3b21a6ec8cb066f962315ce3f2b43f11ca43 Mon Sep 17 00:00:00 2001 From: Alexander Date: Fri, 22 Jan 2016 15:14:34 -0800 Subject: [PATCH] Removed redundant return in labda expressions --- src/main/java/learnrxjava/examples/HelloWorld.java | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/src/main/java/learnrxjava/examples/HelloWorld.java b/src/main/java/learnrxjava/examples/HelloWorld.java index 6694b9f..8f1c220 100644 --- a/src/main/java/learnrxjava/examples/HelloWorld.java +++ b/src/main/java/learnrxjava/examples/HelloWorld.java @@ -134,19 +134,16 @@ public void onNext(String t) { Observable.create(subscriber -> { throw new RuntimeException("failed!"); - }).onErrorReturn(throwable -> { - return "fallback value"; - }).subscribe(System.out::println); + }).onErrorReturn(throwable -> "fallback value") + .subscribe(System.out::println); Observable.create(subscriber -> { throw new RuntimeException("failed!"); - }).retryWhen(attempts -> { - return attempts.zipWith(Observable.range(1, 3), (throwable, i) -> i) + }).retryWhen(attempts -> attempts.zipWith(Observable.range(1, 3), (throwable, i) -> i) .flatMap(i -> { System.out.println("delay retry by " + i + " second(s)"); return Observable.timer(i, TimeUnit.SECONDS); - }).concatWith(Observable.error(new RuntimeException("Exceeded 3 retries"))); - }) + }).concatWith(Observable.error(new RuntimeException("Exceeded 3 retries")))) .subscribe(System.out::println, t -> t.printStackTrace()); try {