Covert to lambda

Author: amitshekhariitbhu

app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java

@@ -3,7 +3,6 @@
 import com.rxjava2.android.samples.ui.cache.model.Data;
 
 import io.reactivex.Observable;
-import io.reactivex.functions.Consumer;
 
 /**
  * The DataSource to handle 3 data sources - memory, disk, network
@@ -27,21 +26,13 @@ public Observable<Data> getDataFromMemory() {
     }
 
     public Observable<Data> getDataFromDisk() {
-        return diskDataSource.getData().doOnNext(new Consumer<Data>() {
-            @Override
-            public void accept(Data data) throws Exception {
-                memoryDataSource.cacheInMemory(data);
-            }
-        });
+        return diskDataSource.getData().doOnNext(memoryDataSource::cacheInMemory);
     }
 
     public Observable<Data> getDataFromNetwork() {
-        return networkDataSource.getData().doOnNext(new Consumer<Data>() {
-            @Override
-            public void accept(Data data) throws Exception {
-                diskDataSource.saveToDisk(data);
-                memoryDataSource.cacheInMemory(data);
-            }
+        return networkDataSource.getData().doOnNext(data -> {
+            diskDataSource.saveToDisk(data);
+            memoryDataSource.cacheInMemory(data);
         });
     }
 

app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java

@@ -3,8 +3,6 @@
 import com.rxjava2.android.samples.ui.cache.model.Data;
 
 import io.reactivex.Observable;
-import io.reactivex.ObservableEmitter;
-import io.reactivex.ObservableOnSubscribe;
 
 /**
  * Class to simulate Disk DataSource
@@ -14,14 +12,11 @@ public class DiskDataSource {
     private Data data;
 
     public Observable<Data> getData() {
-        return Observable.create(new ObservableOnSubscribe<Data>() {
-            @Override
-            public void subscribe(ObservableEmitter<Data> emitter) throws Exception {
-                if (data != null) {
-                    emitter.onNext(data);
-                }
-                emitter.onComplete();
+        return Observable.create(emitter -> {
+            if (data != null) {
+                emitter.onNext(data);
             }
+            emitter.onComplete();
         });
     }
 

app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java

@@ -3,8 +3,6 @@
 import com.rxjava2.android.samples.ui.cache.model.Data;
 
 import io.reactivex.Observable;
-import io.reactivex.ObservableEmitter;
-import io.reactivex.ObservableOnSubscribe;
 
 /**
  * Class to simulate InMemory DataSource
@@ -14,14 +12,11 @@ public class MemoryDataSource {
     private Data data;
 
     public Observable<Data> getData() {
-        return Observable.create(new ObservableOnSubscribe<Data>() {
-            @Override
-            public void subscribe(ObservableEmitter<Data> emitter) throws Exception {
-                if (data != null) {
-                    emitter.onNext(data);
-                }
-                emitter.onComplete();
+        return Observable.create(emitter -> {
+            if (data != null) {
+                emitter.onNext(data);
             }
+            emitter.onComplete();
         });
     }
 

app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java

@@ -3,8 +3,6 @@
 import com.rxjava2.android.samples.ui.cache.model.Data;
 
 import io.reactivex.Observable;
-import io.reactivex.ObservableEmitter;
-import io.reactivex.ObservableOnSubscribe;
 
 
 /**
@@ -13,14 +11,11 @@
 public class NetworkDataSource {
 
     public Observable<Data> getData() {
-        return Observable.create(new ObservableOnSubscribe<Data>() {
-            @Override
-            public void subscribe(ObservableEmitter<Data> emitter) throws Exception {
-                Data data = new Data();
-                data.source = "network";
-                emitter.onNext(data);
-                emitter.onComplete();
-            }
+        return Observable.create(emitter -> {
+            Data data = new Data();
+            data.source = "network";
+            emitter.onNext(data);
+            emitter.onComplete();
         });
     }