From 27cf2bb91a14ced24ae616bc94871d4de9330999 Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 19 Mar 2019 14:04:55 +0530
Subject: [PATCH 01/28] Add Cache Example Using Concat

---
 app/src/main/AndroidManifest.xml              |  6 +-
 .../android/samples/ui/SelectionActivity.java |  5 +
 .../ui/cache/CacheExampleActivity.java        | 93 +++++++++++++++++++
 .../android/samples/ui/cache/model/Data.java  | 12 +++
 .../samples/ui/cache/source/DataSource.java   | 45 +++++++++
 .../ui/cache/source/DiskDataSource.java       | 30 ++++++
 .../ui/cache/source/MemoryDataSource.java     | 31 +++++++
 .../ui/cache/source/NetworkDataSource.java    | 23 +++++
 .../main/res/layout/activity_selection.xml    | 11 ++-
 app/src/main/res/values/strings.xml           |  1 +
 10 files changed, 254 insertions(+), 3 deletions(-)
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/model/Data.java
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
 create mode 100644 app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java

diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
index ec63671..0006b4e 100644
--- a/app/src/main/AndroidManifest.xml
+++ b/app/src/main/AndroidManifest.xml
@@ -24,6 +24,9 @@
         <activity
             android:name=".ui.networking.NetworkingActivity"
             android:label="@string/networking" />
+        <activity
+            android:name=".ui.cache.CacheExampleActivity"
+            android:label="@string/cache" />
         <activity
             android:name=".ui.rxbus.RxBusActivity"
             android:label="@string/rx_bus" />
@@ -126,7 +129,8 @@
         <activity
             android:name=".ui.compose.ComposeOperatorExampleActivity"
             android:label="@string/compose" />
-        <activity android:name=".ui.operators.SwitchMapExampleActivity"
+        <activity
+            android:name=".ui.operators.SwitchMapExampleActivity"
             android:label="@string/switch_map" />
     </application>
 
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java
index d3c6082..b2c88e2 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/SelectionActivity.java
@@ -7,6 +7,7 @@
 
 import com.rxjava2.android.samples.MyApplication;
 import com.rxjava2.android.samples.R;
+import com.rxjava2.android.samples.ui.cache.CacheExampleActivity;
 import com.rxjava2.android.samples.ui.compose.ComposeOperatorExampleActivity;
 import com.rxjava2.android.samples.ui.networking.NetworkingActivity;
 import com.rxjava2.android.samples.ui.pagination.PaginationActivity;
@@ -29,6 +30,10 @@ public void startNetworkingActivity(View view) {
         startActivity(new Intent(SelectionActivity.this, NetworkingActivity.class));
     }
 
+    public void startCacheActivity(View view) {
+        startActivity(new Intent(SelectionActivity.this, CacheExampleActivity.class));
+    }
+
     public void startRxBusActivity(View view) {
         ((MyApplication) getApplication()).sendAutoEvent();
         startActivity(new Intent(SelectionActivity.this, RxBusActivity.class));
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
new file mode 100644
index 0000000..25cc500
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
@@ -0,0 +1,93 @@
+package com.rxjava2.android.samples.ui.cache;
+
+import android.os.Bundle;
+import android.support.v7.app.AppCompatActivity;
+import android.util.Log;
+import android.view.View;
+import android.widget.Button;
+import android.widget.TextView;
+
+import com.rxjava2.android.samples.R;
+import com.rxjava2.android.samples.ui.cache.model.Data;
+import com.rxjava2.android.samples.ui.cache.source.DataSource;
+import com.rxjava2.android.samples.ui.cache.source.DiskDataSource;
+import com.rxjava2.android.samples.ui.cache.source.MemoryDataSource;
+import com.rxjava2.android.samples.ui.cache.source.NetworkDataSource;
+import com.rxjava2.android.samples.utils.AppConstant;
+
+import io.reactivex.Observable;
+import io.reactivex.Observer;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.schedulers.Schedulers;
+
+public class CacheExampleActivity extends AppCompatActivity {
+
+    private static final String TAG = CacheExampleActivity.class.getSimpleName();
+    Button btn;
+    TextView textView;
+    DataSource dataSource;
+
+    @Override
+    protected void onCreate(Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+        setContentView(R.layout.activity_example);
+        btn = (Button) findViewById(R.id.btn);
+        textView = (TextView) findViewById(R.id.textView);
+
+        btn.setOnClickListener(new View.OnClickListener() {
+            @Override
+            public void onClick(View view) {
+                doSomeWork();
+            }
+        });
+
+        dataSource = new DataSource(new MemoryDataSource(), new DiskDataSource(), new NetworkDataSource());
+    }
+
+    private void doSomeWork() {
+
+        Observable<Data> memory = dataSource.getDataFromMemory();
+        Observable<Data> disk = dataSource.getDataFromDisk();
+        Observable<Data> network = dataSource.getDataFromNetwork();
+
+        Observable.concat(memory, disk, network)
+                .firstElement()
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .toObservable()
+                .subscribe(getObserver());
+    }
+
+    private Observer<Data> getObserver() {
+        return new Observer<Data>() {
+
+            @Override
+            public void onSubscribe(Disposable d) {
+                Log.d(TAG, " onSubscribe : " + d.isDisposed());
+            }
+
+            @Override
+            public void onNext(Data data) {
+                textView.append(" onNext : " + data.source);
+                textView.append(AppConstant.LINE_SEPARATOR);
+                Log.d(TAG, " onNext : " + data.source);
+            }
+
+            @Override
+            public void onError(Throwable e) {
+                textView.append(" onError : " + e.getMessage());
+                textView.append(AppConstant.LINE_SEPARATOR);
+                Log.d(TAG, " onError : " + e.getMessage());
+            }
+
+            @Override
+            public void onComplete() {
+                textView.append(" onComplete");
+                textView.append(AppConstant.LINE_SEPARATOR);
+                Log.d(TAG, " onComplete");
+            }
+        };
+    }
+
+}
\ No newline at end of file
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/model/Data.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/model/Data.java
new file mode 100644
index 0000000..477144e
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/model/Data.java
@@ -0,0 +1,12 @@
+package com.rxjava2.android.samples.ui.cache.model;
+
+public class Data {
+
+    public String source;
+
+    @SuppressWarnings("CloneDoesntDeclareCloneNotSupportedException")
+    @Override
+    public Data clone() {
+        return new Data();
+    }
+}
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
new file mode 100644
index 0000000..f0297ed
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
@@ -0,0 +1,45 @@
+package com.rxjava2.android.samples.ui.cache.source;
+
+import com.rxjava2.android.samples.ui.cache.model.Data;
+
+import io.reactivex.Observable;
+import io.reactivex.functions.Consumer;
+
+public class DataSource {
+
+    private final MemoryDataSource memoryDataSource;
+    private final DiskDataSource diskDataSource;
+    private final NetworkDataSource networkDataSource;
+
+    public DataSource(MemoryDataSource memoryDataSource,
+                      DiskDataSource diskDataSource,
+                      NetworkDataSource networkDataSource) {
+        this.memoryDataSource = memoryDataSource;
+        this.diskDataSource = diskDataSource;
+        this.networkDataSource = networkDataSource;
+    }
+
+    public Observable<Data> getDataFromMemory() {
+        return memoryDataSource.getData();
+    }
+
+    public Observable<Data> getDataFromDisk() {
+        return diskDataSource.getData().doOnNext(new Consumer<Data>() {
+            @Override
+            public void accept(Data data) throws Exception {
+                memoryDataSource.cacheInMemory(data);
+            }
+        });
+    }
+
+    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);
+            }
+        });
+    }
+
+}
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
new file mode 100644
index 0000000..2d9628b
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
@@ -0,0 +1,30 @@
+package com.rxjava2.android.samples.ui.cache.source;
+
+import com.rxjava2.android.samples.ui.cache.model.Data;
+
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.ObservableOnSubscribe;
+
+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();
+            }
+        });
+    }
+
+    public void saveToDisk(Data data) {
+        this.data = data.clone();
+        this.data.source = "disk";
+    }
+
+}
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
new file mode 100644
index 0000000..215d63c
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
@@ -0,0 +1,31 @@
+package com.rxjava2.android.samples.ui.cache.source;
+
+import com.rxjava2.android.samples.ui.cache.model.Data;
+
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.ObservableOnSubscribe;
+
+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();
+            }
+        });
+    }
+
+    public void cacheInMemory(Data data) {
+        this.data = data.clone();
+        this.data.source = "memory";
+
+    }
+
+}
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
new file mode 100644
index 0000000..632fde8
--- /dev/null
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
@@ -0,0 +1,23 @@
+package com.rxjava2.android.samples.ui.cache.source;
+
+import com.rxjava2.android.samples.ui.cache.model.Data;
+
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.ObservableOnSubscribe;
+
+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();
+            }
+        });
+    }
+
+}
diff --git a/app/src/main/res/layout/activity_selection.xml b/app/src/main/res/layout/activity_selection.xml
index 2c42930..999f99c 100644
--- a/app/src/main/res/layout/activity_selection.xml
+++ b/app/src/main/res/layout/activity_selection.xml
@@ -4,10 +4,10 @@
     android:layout_width="match_parent"
     android:layout_height="match_parent"
     android:fadeScrollbars="false"
-    android:paddingBottom="@dimen/activity_vertical_margin"
     android:paddingLeft="@dimen/activity_horizontal_margin"
-    android:paddingRight="@dimen/activity_horizontal_margin"
     android:paddingTop="@dimen/activity_vertical_margin"
+    android:paddingRight="@dimen/activity_horizontal_margin"
+    android:paddingBottom="@dimen/activity_vertical_margin"
     tools:context="com.rxjava2.android.samples.ui.SelectionActivity">
 
     <LinearLayout
@@ -29,6 +29,13 @@
             android:text="@string/networking"
             android:textColor="@android:color/black" />
 
+        <Button
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:onClick="startCacheActivity"
+            android:text="@string/cache"
+            android:textColor="@android:color/black" />
+
         <Button
             android:layout_width="match_parent"
             android:layout_height="wrap_content"
diff --git a/app/src/main/res/values/strings.xml b/app/src/main/res/values/strings.xml
index 8f3273f..90e11b9 100644
--- a/app/src/main/res/values/strings.xml
+++ b/app/src/main/res/values/strings.xml
@@ -3,6 +3,7 @@
     <string name="doSomeWork">doSomeWork</string>
     <string name="operators">Operators</string>
     <string name="networking">Networking</string>
+    <string name="cache">Cache</string>
     <string name="pagination">Pagination</string>
     <string name="search">Search</string>
     <string name="simple">Simple</string>

From 1d7b06a17311a75eb6dee2078d8b0821c2415b56 Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 19 Mar 2019 14:13:55 +0530
Subject: [PATCH 02/28] Add comments for cache

---
 .../android/samples/ui/cache/CacheExampleActivity.java        | 2 +-
 .../rxjava2/android/samples/ui/cache/source/DataSource.java   | 3 +++
 .../android/samples/ui/cache/source/DiskDataSource.java       | 3 +++
 .../android/samples/ui/cache/source/MemoryDataSource.java     | 4 +++-
 .../android/samples/ui/cache/source/NetworkDataSource.java    | 4 ++++
 5 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
index 25cc500..bd98f63 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java
@@ -1,7 +1,6 @@
 package com.rxjava2.android.samples.ui.cache;
 
 import android.os.Bundle;
-import android.support.v7.app.AppCompatActivity;
 import android.util.Log;
 import android.view.View;
 import android.widget.Button;
@@ -15,6 +14,7 @@
 import com.rxjava2.android.samples.ui.cache.source.NetworkDataSource;
 import com.rxjava2.android.samples.utils.AppConstant;
 
+import androidx.appcompat.app.AppCompatActivity;
 import io.reactivex.Observable;
 import io.reactivex.Observer;
 import io.reactivex.android.schedulers.AndroidSchedulers;
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
index f0297ed..1848c89 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
@@ -5,6 +5,9 @@
 import io.reactivex.Observable;
 import io.reactivex.functions.Consumer;
 
+/**
+ * The DataSource to handle 3 data sources - memory, disk, network
+ */
 public class DataSource {
 
     private final MemoryDataSource memoryDataSource;
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
index 2d9628b..168e998 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
@@ -6,6 +6,9 @@
 import io.reactivex.ObservableEmitter;
 import io.reactivex.ObservableOnSubscribe;
 
+/**
+ * Class to simulate Disk DataSource
+ */
 public class DiskDataSource {
 
     private Data data;
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
index 215d63c..4c83a19 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
@@ -6,6 +6,9 @@
 import io.reactivex.ObservableEmitter;
 import io.reactivex.ObservableOnSubscribe;
 
+/**
+ * Class to simulate InMemory DataSource
+ */
 public class MemoryDataSource {
 
     private Data data;
@@ -25,7 +28,6 @@ public void subscribe(ObservableEmitter<Data> emitter) throws Exception {
     public void cacheInMemory(Data data) {
         this.data = data.clone();
         this.data.source = "memory";
-
     }
 
 }
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
index 632fde8..1d0d666 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
@@ -6,6 +6,10 @@
 import io.reactivex.ObservableEmitter;
 import io.reactivex.ObservableOnSubscribe;
 
+
+/**
+ * Class to simulate Network DataSource
+ */
 public class NetworkDataSource {
 
     public Observable<Data> getData() {

From 3941eba77eb98bf86125dace2a8c361f676af505 Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 19 Mar 2019 14:43:36 +0530
Subject: [PATCH 03/28] Covert to lambda

---
 .../samples/ui/cache/source/DataSource.java     | 17 ++++-------------
 .../samples/ui/cache/source/DiskDataSource.java | 13 ++++---------
 .../ui/cache/source/MemoryDataSource.java       | 13 ++++---------
 .../ui/cache/source/NetworkDataSource.java      | 15 +++++----------
 4 files changed, 17 insertions(+), 41 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
index 1848c89..3f7e5d9 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
+++ b/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);
         });
     }
 
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
index 168e998..29f5bfa 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DiskDataSource.java
+++ b/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();
         });
     }
 
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
index 4c83a19..2742f26 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/MemoryDataSource.java
+++ b/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();
         });
     }
 
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
index 1d0d666..d903fb0 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/NetworkDataSource.java
+++ b/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();
         });
     }
 

From f49406b3619be76474dde90e435844cbeec4e024 Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 19 Mar 2019 15:39:02 +0530
Subject: [PATCH 04/28] Remove method reference

---
 .../rxjava2/android/samples/ui/cache/source/DataSource.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
index 3f7e5d9..23403ff 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/cache/source/DataSource.java
@@ -26,7 +26,9 @@ public Observable<Data> getDataFromMemory() {
     }
 
     public Observable<Data> getDataFromDisk() {
-        return diskDataSource.getData().doOnNext(memoryDataSource::cacheInMemory);
+        return diskDataSource.getData().doOnNext(data ->
+                memoryDataSource.cacheInMemory(data)
+        );
     }
 
     public Observable<Data> getDataFromNetwork() {

From e483609bd510b2d878254b86f455af932f2b919b Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 19 Mar 2019 17:02:22 +0530
Subject: [PATCH 05/28] Add Implement Caching Using RxJava Operators

---
 README.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/README.md b/README.md
index 1e1d05a..777e4d8 100644
--- a/README.md
+++ b/README.md
@@ -108,6 +108,7 @@ RxJava1 -> RxJava2
 * [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView
 * [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
 * [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`, [Blog for reference](https://blog.mindorks.com/implement-search-using-rxjava-operators-c8882b64fe1d)
+* [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`, [Blog for reference](https://blog.mindorks.com/implement-caching-in-android-using-rxjava-operators)
 * [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java)
 
 ### TODO 

From 3037e3ba55a5b007626527d61fde2a7dc142d98b Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Wed, 20 Mar 2019 17:55:35 +0530
Subject: [PATCH 06/28] Add Zip Blog

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 777e4d8..ee8782f 100644
--- a/README.md
+++ b/README.md
@@ -92,7 +92,7 @@ RxJava1 -> RxJava2
 * [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
 * [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`
 * [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator
-* [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator
+* [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator, [Blog for reference](https://blog.mindorks.com/understanding-rxjava-zip-operator-with-example)
 * [BufferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java) - Using `buffer` Operator
 * [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator
 * [ReduceExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java) - Using `reduce` Operator

From 44924bda17a8724aaf77cedb4bed87b537a830da Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Wed, 27 Mar 2019 15:02:43 +0530
Subject: [PATCH 07/28] Add Schedulers in each observable in Zip Example

---
 .../samples/ui/operators/ZipExampleActivity.java   | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java
index 18c97f3..11cb394 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java
@@ -48,11 +48,11 @@ public void onClick(View view) {
     }
 
     /*
-    * Here we are getting two user list
-    * One, the list of cricket fans
-    * Another one, the list of football fans
-    * Then we are finding the list of users who loves both
-    */
+     * Here we are getting two user list
+     * One, the list of cricket fans
+     * Another one, the list of football fans
+     * Then we are finding the list of users who loves both
+     */
     private void doSomeWork() {
         Observable.zip(getCricketFansObservable(), getFootballFansObservable(),
                 new BiFunction<List<User>, List<User>, List<User>>() {
@@ -77,7 +77,7 @@ public void subscribe(ObservableEmitter<List<User>> e) {
                     e.onComplete();
                 }
             }
-        });
+        }).subscribeOn(Schedulers.io());
     }
 
     private Observable<List<User>> getFootballFansObservable() {
@@ -89,7 +89,7 @@ public void subscribe(ObservableEmitter<List<User>> e) {
                     e.onComplete();
                 }
             }
-        });
+        }).subscribeOn(Schedulers.io());
     }
 
     private Observer<List<User>> getObserver() {

From 705bb84a5fbd3d4a36755f17c6e08cfa705b0d7f Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Sun, 7 Apr 2019 15:00:27 +0530
Subject: [PATCH 08/28] Change Flowable to Single in Pagination

---
 .../ui/pagination/PaginationActivity.java     | 53 ++++++++-----------
 app/src/main/res/layout/item_pagination.xml   |  2 +-
 2 files changed, 23 insertions(+), 32 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
index 2cca2d7..202be46 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
@@ -6,8 +6,6 @@
 
 import com.rxjava2.android.samples.R;
 
-import org.reactivestreams.Publisher;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -15,14 +13,12 @@
 import androidx.appcompat.app.AppCompatActivity;
 import androidx.recyclerview.widget.LinearLayoutManager;
 import androidx.recyclerview.widget.RecyclerView;
-import io.reactivex.Flowable;
+import io.reactivex.Single;
 import io.reactivex.android.schedulers.AndroidSchedulers;
-import io.reactivex.annotations.NonNull;
 import io.reactivex.disposables.CompositeDisposable;
 import io.reactivex.disposables.Disposable;
-import io.reactivex.functions.Consumer;
-import io.reactivex.functions.Function;
 import io.reactivex.processors.PublishProcessor;
+import io.reactivex.schedulers.Schedulers;
 
 /**
  * Created by amitshekhar on 15/03/17.
@@ -94,23 +90,21 @@ private void subscribeForData() {
 
         Disposable disposable = paginator
                 .onBackpressureDrop()
-                .concatMap(new Function<Integer, Publisher<List<String>>>() {
-                    @Override
-                    public Publisher<List<String>> apply(@NonNull Integer page) {
-                        loading = true;
-                        progressBar.setVisibility(View.VISIBLE);
-                        return dataFromNetwork(page);
-                    }
+                .doOnNext(page -> {
+                    loading = true;
+                    progressBar.setVisibility(View.VISIBLE);
                 })
+                .concatMapSingle(page -> dataFromNetwork(page)
+                        .subscribeOn(Schedulers.io())
+                        .doOnError(throwable -> {
+                            // handle error
+                        }))
                 .observeOn(AndroidSchedulers.mainThread())
-                .subscribe(new Consumer<List<String>>() {
-                    @Override
-                    public void accept(@NonNull List<String> items) {
-                        paginationAdapter.addItems(items);
-                        paginationAdapter.notifyDataSetChanged();
-                        loading = false;
-                        progressBar.setVisibility(View.INVISIBLE);
-                    }
+                .subscribe(items -> {
+                    paginationAdapter.addItems(items);
+                    paginationAdapter.notifyDataSetChanged();
+                    loading = false;
+                    progressBar.setVisibility(View.INVISIBLE);
                 });
 
         compositeDisposable.add(disposable);
@@ -122,18 +116,15 @@ public void accept(@NonNull List<String> items) {
     /**
      * Simulation of network data
      */
-    private Flowable<List<String>> dataFromNetwork(final int page) {
-        return Flowable.just(true)
+    private Single<List<String>> dataFromNetwork(final int page) {
+        return Single.just(true)
                 .delay(2, TimeUnit.SECONDS)
-                .map(new Function<Boolean, List<String>>() {
-                    @Override
-                    public List<String> apply(@NonNull Boolean value) {
-                        List<String> items = new ArrayList<>();
-                        for (int i = 1; i <= 10; i++) {
-                            items.add("Item " + (page * 10 + i));
-                        }
-                        return items;
+                .map(value -> {
+                    List<String> items = new ArrayList<>();
+                    for (int i = 1; i <= 10; i++) {
+                        items.add("Item " + (page * 10 + i));
                     }
+                    return items;
                 });
     }
 }
diff --git a/app/src/main/res/layout/item_pagination.xml b/app/src/main/res/layout/item_pagination.xml
index 3e38887..5f1bfc2 100644
--- a/app/src/main/res/layout/item_pagination.xml
+++ b/app/src/main/res/layout/item_pagination.xml
@@ -5,4 +5,4 @@
     android:layout_width="match_parent"
     android:layout_height="wrap_content"
     android:padding="@dimen/activity_horizontal_margin"
-    android:textSize="20sp" />
\ No newline at end of file
+    android:textSize="32sp" />
\ No newline at end of file

From 4a9bc275aff6824b4373a0cbadeab5d07a497cac Mon Sep 17 00:00:00 2001
From: amitshekhariitbhu <amit.shekhar.iitbhu@gmail.com>
Date: Thu, 30 May 2019 11:04:29 +0530
Subject: [PATCH 09/28] Add scheduleOn for zip

---
 .../ui/networking/NetworkingActivity.java     | 21 +++++++++++--------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java
index a425a96..6878e3a 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/networking/NetworkingActivity.java
@@ -5,6 +5,8 @@
 import android.util.Pair;
 import android.view.View;
 
+import androidx.appcompat.app.AppCompatActivity;
+
 import com.rx2androidnetworking.Rx2AndroidNetworking;
 import com.rxjava2.android.samples.R;
 import com.rxjava2.android.samples.model.ApiUser;
@@ -15,7 +17,6 @@
 import java.util.ArrayList;
 import java.util.List;
 
-import androidx.appcompat.app.AppCompatActivity;
 import io.reactivex.Observable;
 import io.reactivex.ObservableSource;
 import io.reactivex.Observer;
@@ -93,23 +94,25 @@ public void onComplete() {
     private Observable<List<User>> getCricketFansObservable() {
         return Rx2AndroidNetworking.get("https://fierce-cove-29863.herokuapp.com/getAllCricketFans")
                 .build()
-                .getObjectListObservable(User.class);
+                .getObjectListObservable(User.class)
+                .subscribeOn(Schedulers.io());
     }
 
     /*
-    * This observable return the list of User who loves Football
-    */
+     * This observable return the list of User who loves Football
+     */
     private Observable<List<User>> getFootballFansObservable() {
         return Rx2AndroidNetworking.get("https://fierce-cove-29863.herokuapp.com/getAllFootballFans")
                 .build()
-                .getObjectListObservable(User.class);
+                .getObjectListObservable(User.class)
+                .subscribeOn(Schedulers.io());
     }
 
     /*
-    * This do the complete magic, make both network call
-    * and then returns the list of user who loves both
-    * Using zip operator to get both response at a time
-    */
+     * This do the complete magic, make both network call
+     * and then returns the list of user who loves both
+     * Using zip operator to get both response at a time
+     */
     private void findUsersWhoLovesBoth() {
         // here we are using zip operator to combine both request
         Observable.zip(getCricketFansObservable(), getFootballFansObservable(),

From a311cf860205578eb945fd1f954dea02cd65d392 Mon Sep 17 00:00:00 2001
From: amitshekhar <amit.shekhar.iitbhu@gmail.com>
Date: Mon, 1 Jul 2019 21:19:24 +0530
Subject: [PATCH 10/28] Add Course link

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index ee8782f..e50cf72 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@
 [![Open Source Love](https://badges.frapsoft.com/os/v1/open-source.svg?v=102)](https://opensource.org/licenses/Apache-2.0)
 [![License](https://img.shields.io/badge/license-Apache%202.0-blue.svg)](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/LICENSE)
 
-### Get the complete RxJava Course [here](https://mindorks.com/course/learn-rxjava)
+### [Take the MindOrks Android Online Course and Learn RxJava](https://bootcamp.mindorks.com)
 
 ## How to use RxJava 2 in Android Application
 ## How to migrate from RxJava 1.0 to RxJava 2.0

From 5e156ae216e3b3fc8d406d7aa75ad0b71a0e173a Mon Sep 17 00:00:00 2001
From: amitshekhar <amit.shekhar.iitbhu@gmail.com>
Date: Sat, 21 Sep 2019 09:03:36 +0530
Subject: [PATCH 11/28] Add onErrroReturn

---
 .../samples/ui/pagination/PaginationActivity.java     | 11 +++++++----
 .../android/samples/ui/search/SearchActivity.java     | 10 ++++++++--
 2 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
index 202be46..e9c89a9 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java
@@ -4,15 +4,16 @@
 import android.view.View;
 import android.widget.ProgressBar;
 
+import androidx.appcompat.app.AppCompatActivity;
+import androidx.recyclerview.widget.LinearLayoutManager;
+import androidx.recyclerview.widget.RecyclerView;
+
 import com.rxjava2.android.samples.R;
 
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
-import androidx.appcompat.app.AppCompatActivity;
-import androidx.recyclerview.widget.LinearLayoutManager;
-import androidx.recyclerview.widget.RecyclerView;
 import io.reactivex.Single;
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.CompositeDisposable;
@@ -98,7 +99,9 @@ private void subscribeForData() {
                         .subscribeOn(Schedulers.io())
                         .doOnError(throwable -> {
                             // handle error
-                        }))
+                        })
+                            // continue emission in case of error also
+                        .onErrorReturn(throwable -> new ArrayList<>()))
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(items -> {
                     paginationAdapter.addItems(items);
diff --git a/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java b/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java
index 9086b01..d9353c9 100644
--- a/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java
+++ b/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java
@@ -4,11 +4,12 @@
 import android.widget.SearchView;
 import android.widget.TextView;
 
+import androidx.appcompat.app.AppCompatActivity;
+
 import com.rxjava2.android.samples.R;
 
 import java.util.concurrent.TimeUnit;
 
-import androidx.appcompat.app.AppCompatActivity;
 import io.reactivex.Observable;
 import io.reactivex.ObservableSource;
 import io.reactivex.android.schedulers.AndroidSchedulers;
@@ -56,7 +57,12 @@ public boolean test(String text) {
                 .switchMap(new Function<String, ObservableSource<String>>() {
                     @Override
                     public ObservableSource<String> apply(String query) {
-                        return dataFromNetwork(query);
+                        return dataFromNetwork(query)
+                                .doOnError(throwable -> {
+                                    // handle error
+                                })
+                                // continue emission in case of error also
+                                .onErrorReturn(throwable -> "");
                     }
                 })
                 .subscribeOn(Schedulers.io())

From c91b115648b9ff08b9d6441a03c4d2f511ca09de Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 12 Nov 2019 22:14:31 +0530
Subject: [PATCH 12/28] Update README.md

---
 README.md | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/README.md b/README.md
index e50cf72..d31d263 100644
--- a/README.md
+++ b/README.md
@@ -12,6 +12,7 @@
 
 ## How to use RxJava 2 in Android Application
 ## How to migrate from RxJava 1.0 to RxJava 2.0
+## How to use RxJava 3 in Android Application [Check here](https://github.com/MindorksOpenSource/RxJava3-Android-Examples)
 
 ### This project is for : 
 * who is migrating to RxJava 2 
@@ -82,7 +83,7 @@ RxJava1 -> RxJava2
 * `Concat` -> emit the emissions from two or more Observables without interleaving them
 * `Replay` -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
 * `Merge` -> combine multiple Observables into one by merging their emissions
-* `SwitchMap` -> ransform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
+* `SwitchMap` -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
 
 
 # Highlights of the examples :

From 001db6767810f3c7958129cbad5c74b813a5b1dd Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Thu, 26 Mar 2020 19:22:40 +0530
Subject: [PATCH 13/28] Update README.md

---
 README.md | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/README.md b/README.md
index d31d263..99fa4e4 100644
--- a/README.md
+++ b/README.md
@@ -131,6 +131,10 @@ RxJava1 -> RxJava2
 ### Another awesome library for debugging databases and shared preferences.
 * [Android Debug Database](https://github.com/amitshekhariitbhu/Android-Debug-Database)
 
+
+### Learn to build a ride-sharing Android app like Uber, Lyft.
+* [Check here](https://github.com/MindorksOpenSource/ridesharing-uber-lyft-app)
+
 ### [Check out Mindorks awesome open source projects here](https://mindorks.com/open-source-projects)
 
 ### Contact - Let's become friend

From b5503dea6796bfd4792706fd8e070c64564311c8 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Mon, 20 Apr 2020 23:20:23 +0530
Subject: [PATCH 14/28] Update README.md

---
 README.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/README.md b/README.md
index 99fa4e4..8cc71ad 100644
--- a/README.md
+++ b/README.md
@@ -13,6 +13,7 @@
 ## How to use RxJava 2 in Android Application
 ## How to migrate from RxJava 1.0 to RxJava 2.0
 ## How to use RxJava 3 in Android Application [Check here](https://github.com/MindorksOpenSource/RxJava3-Android-Examples)
+## Kotlin-Coroutines-Android-Examples - [Check here](https://github.com/MindorksOpenSource/Kotlin-Coroutines-Android-Examples)
 
 ### This project is for : 
 * who is migrating to RxJava 2 

From 30ef1de9b23f8e277b4e48afe2606239f845bd6e Mon Sep 17 00:00:00 2001
From: anandgaurav10 <anandgaurav9295@gmail.com>
Date: Sat, 28 May 2022 17:14:27 +0530
Subject: [PATCH 15/28] Add .github

---
 .github/FUNDING.yml | 13 +++++++++++++
 1 file changed, 13 insertions(+)
 create mode 100644 .github/FUNDING.yml

diff --git a/.github/FUNDING.yml b/.github/FUNDING.yml
new file mode 100644
index 0000000..cd443a1
--- /dev/null
+++ b/.github/FUNDING.yml
@@ -0,0 +1,13 @@
+# These are supported funding model platforms
+
+github: # Replace with up to 4 GitHub Sponsors-enabled usernames e.g., [user1, user2]
+patreon: # Replace with a single Patreon username
+open_collective: # Replace with a single Open Collective username
+ko_fi: # Replace with a single Ko-fi username
+tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
+community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
+liberapay: # Replace with a single Liberapay username
+issuehunt: # Replace with a single IssueHunt username
+otechie: # Replace with a single Otechie username
+lfx_crowdfunding: # Replace with a single LFX Crowdfunding project-name e.g., cloud-foundry
+custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

From 49e3dcdfaed070e43a4386f0d2a765c93bc7486c Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Sun, 4 Sep 2022 11:04:46 +0530
Subject: [PATCH 16/28] Update .github

---
 .github/FUNDING.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/.github/FUNDING.yml b/.github/FUNDING.yml
index cd443a1..25c1f0e 100644
--- a/.github/FUNDING.yml
+++ b/.github/FUNDING.yml
@@ -1,6 +1,6 @@
 # These are supported funding model platforms
 
-github: # Replace with up to 4 GitHub Sponsors-enabled usernames e.g., [user1, user2]
+github: [amitshekhariitbhu]
 patreon: # Replace with a single Patreon username
 open_collective: # Replace with a single Open Collective username
 ko_fi: # Replace with a single Ko-fi username

From 700d3b4e39a5cdfb7af459d801be67503aa333dc Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Fri, 16 Sep 2022 14:23:10 +0530
Subject: [PATCH 17/28] Update README.md

---
 README.md | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index 8cc71ad..c8565e6 100644
--- a/README.md
+++ b/README.md
@@ -8,17 +8,16 @@
 [![Open Source Love](https://badges.frapsoft.com/os/v1/open-source.svg?v=102)](https://opensource.org/licenses/Apache-2.0)
 [![License](https://img.shields.io/badge/license-Apache%202.0-blue.svg)](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/LICENSE)
 
-### [Take the MindOrks Android Online Course and Learn RxJava](https://bootcamp.mindorks.com)
 
-## How to use RxJava 2 in Android Application
-## How to migrate from RxJava 1.0 to RxJava 2.0
-## How to use RxJava 3 in Android Application [Check here](https://github.com/MindorksOpenSource/RxJava3-Android-Examples)
-## Kotlin-Coroutines-Android-Examples - [Check here](https://github.com/MindorksOpenSource/Kotlin-Coroutines-Android-Examples)
+### How to use RxJava 2 in Android Application
+### How to migrate from RxJava 1.0 to RxJava 2.0
 
 ### This project is for : 
 * who is migrating to RxJava 2 
 * or just started with RxJava.
 
+## [My Personal Blog - amitshekhar.me](https://amitshekhar.me/blog) - High-quality content to learn Android concepts.
+
 ### Just Build the project and start learning RxJava by examples.
 
 RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries.

From 1cb52efcf8f381eb3b976e2ea388e38fa0b72dd6 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Mon, 3 Oct 2022 11:18:32 +0530
Subject: [PATCH 18/28] Update README.md

---
 README.md | 162 ------------------------------------------------------
 1 file changed, 162 deletions(-)

diff --git a/README.md b/README.md
index c8565e6..1995538 100644
--- a/README.md
+++ b/README.md
@@ -1,167 +1,5 @@
 <img src=https://raw.githubusercontent.com/amitshekhariitbhu/RxJava2-Android-Samples/master/assets/rxjava2.png >
 
-# Learning RxJava 2 for Android by example
 
-[![Mindorks](https://img.shields.io/badge/mindorks-opensource-blue.svg)](https://mindorks.com/open-source-projects)
-[![Mindorks Community](https://img.shields.io/badge/join-community-blue.svg)](https://mindorks.com/join-community)
-[![Mindorks Android Store](https://img.shields.io/badge/Mindorks%20Android%20Store-RxJava2%20Android%20Samples-blue.svg?style=flat)](https://mindorks.com/android/store)
-[![Open Source Love](https://badges.frapsoft.com/os/v1/open-source.svg?v=102)](https://opensource.org/licenses/Apache-2.0)
-[![License](https://img.shields.io/badge/license-Apache%202.0-blue.svg)](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/LICENSE)
-
-
-### How to use RxJava 2 in Android Application
-### How to migrate from RxJava 1.0 to RxJava 2.0
-
-### This project is for : 
-* who is migrating to RxJava 2 
-* or just started with RxJava.
-
-## [My Personal Blog - amitshekhar.me](https://amitshekhar.me/blog) - High-quality content to learn Android concepts.
-
-### Just Build the project and start learning RxJava by examples.
-
-RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries.
-
-Because Reactive-Streams has a different architecture, it mandates changes to some well known RxJava types.
-
-
-# Migration From RxJava 1.0 to RxJava 2.0
-
-To allow having RxJava 1 and RxJava 2 side-by-side, RxJava 2 is under the maven coordinates 
-io.reactivex.rxjava2:rxjava:2.x.y and classes are accessible below io.reactivex.
-
-Users switching from 1.x to 2.x have to re-organize their imports, but carefully.
-
-### Using RxJava 2.0 Library in your application
-
-Add this in your build.gradle
-```groovy
-compile 'io.reactivex.rxjava2:rxjava:2.2.2'
-```
-If you are using RxAndroid also, then add the following
-```groovy
-compile 'io.reactivex.rxjava2:rxandroid:2.1.0'
-```
-
-# RxJava 2 Examples present in this sample project
-
-* RxJava 2.0 Example using `CompositeDisposable` as `CompositeSubscription` and `Subscription` have
-been removed.
-
-* RxJava 2 Example using `Flowable`.
-
-* RxJava 2 Example using `SingleObserver`, `CompletableObserver`.
-
-* RxJava 2 Example using RxJava2 operators such as `map, zip, take, reduce, flatMap, filter, buffer, skip, merge, concat, replay`, and much more:
-
-* RxJava 2 Android Samples using `Function` as `Func1` has been removed.
-
-* RxJava 2 Android Samples  using `BiFunction` as `Func2` has been removed.
-
-* And many others android examples
-
-# Quick Look on few changes done in RxJava2 over RxJava1
-
-RxJava1 -> RxJava2
-
-* `onCompleted` -> `onComplete` - without the trailing d
-* `Func1` -> `Function`
-* `Func2` -> `BiFunction`
-* `CompositeSubscription` -> `CompositeDisposable`
-* `limit` operator has been removed - Use `take` in RxJava2
-* and much more.
-
-# Operators :
-* `Map` -> transform the items emitted by an Observable by applying a function to each item
-* `Zip` -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
-* `Filter` -> emit only those items from an Observable that pass a predicate test
-* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable
-* `Take` -> emit only the first n items emitted by an Observable
-* `Reduce` -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
-* `Skip` -> suppress the first n items emitted by an Observable
-* `Buffer` -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
-* `Concat` -> emit the emissions from two or more Observables without interleaving them
-* `Replay` -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
-* `Merge` -> combine multiple Observables into one by merging their emissions
-* `SwitchMap` -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
-
-
-# Highlights of the examples :
-
-* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`
-* [FlowableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java) - Using `Flowable` and `reduce` operator
-* [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
-* [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`
-* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator
-* [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator, [Blog for reference](https://blog.mindorks.com/understanding-rxjava-zip-operator-with-example)
-* [BufferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java) - Using `buffer` Operator
-* [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator
-* [ReduceExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java) - Using `reduce` Operator
-* [FilterExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java) - Using `filter` Operator
-* [SkipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java) - Using `skip` Operator
-* [ReplayExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java) - Using `replay` Operator
-* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator
-* [MergeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java) - Using `merge` Operator
-* [DeferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java) - Using `defer` Observable
-* [SwitchMapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SwitchMapExampleActivity.java) - Using `switchMap` Observable
-* [IntervalExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java) - Using `Interval`
-* [RxBusActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/rxbus/RxBusActivity.java) - RxBus, RxJava2Bus, EventBus, RxEventBus, [Blog for reference](https://blog.mindorks.com/implementing-eventbus-with-rxjava-rxbus-e6c940a94bd8)
-* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView
-* [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
-* [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`, [Blog for reference](https://blog.mindorks.com/implement-search-using-rxjava-operators-c8882b64fe1d)
-* [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`, [Blog for reference](https://blog.mindorks.com/implement-caching-in-android-using-rxjava-operators)
-* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java)
-
-### TODO 
-
-* Many examples are to be added 
-
-### Find this project useful ? :heart:
-* Support it by clicking the :star: button on the upper right of this page. :v:
-
-### Check out an awesome MVP architecture based project which uses RxJava2, Dagger2.
-* [Android-MVP-Architecture](https://github.com/MindorksOpenSource/android-mvp-architecture)
-
-### Check out an awesome Kotlin MVP architecture based project which uses RxJava2, Dagger2.
-* [Android-Kotlin-MVP-Architecture](https://github.com/MindorksOpenSource/android-kotlin-mvp-architecture)
-
-### Check out an awesome library for fast and simple networking in Android.
-* [Fast Android Networking Library](https://github.com/amitshekhariitbhu/Fast-Android-Networking)
-
-### Another awesome library for debugging databases and shared preferences.
-* [Android Debug Database](https://github.com/amitshekhariitbhu/Android-Debug-Database)
-
-
-### Learn to build a ride-sharing Android app like Uber, Lyft.
-* [Check here](https://github.com/MindorksOpenSource/ridesharing-uber-lyft-app)
-
-### [Check out Mindorks awesome open source projects here](https://mindorks.com/open-source-projects)
-
-### Contact - Let's become friend
-- [Twitter](https://twitter.com/amitiitbhu)
-- [Github](https://github.com/amitshekhariitbhu)
-- [Medium](https://medium.com/@amitshekhar)
-- [Facebook](https://www.facebook.com/amit.shekhar.iitbhu)
-
-### License
-```
-   Copyright (C) 2016 Amit Shekhar
-   Copyright (C) 2011 Android Open Source Project
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
-```
-
-### Contributing to RxJava 2 Android Samples
-Just make pull request. You are in!
 
  

From 21f6e7f465544b229f8bc44200c5da52b68b81c0 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Mon, 3 Oct 2022 11:23:51 +0530
Subject: [PATCH 19/28] Update README.md

---
 README.md | 98 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 98 insertions(+)

diff --git a/README.md b/README.md
index 1995538..79aff5f 100644
--- a/README.md
+++ b/README.md
@@ -1,5 +1,103 @@
 <img src=https://raw.githubusercontent.com/amitshekhariitbhu/RxJava2-Android-Samples/master/assets/rxjava2.png >
 
+# Learning RxJava 2 for Android by example
 
+### This project is for : 
+* who is migrating to RxJava 2 
+* or just started with RxJava.
 
+## [My Personal Blog - amitshekhar.me](https://amitshekhar.me/blog) - High-quality content to learn Android concepts.
+
+### Just Build the project and start learning RxJava by examples.
+
+RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries.
+
+### Using RxJava 2.0 Library in your application
+
+Add this in your build.gradle
+```groovy
+compile 'io.reactivex.rxjava2:rxjava:X.X.X'
+```
+If you are using RxAndroid also, then add the following
+```groovy
+compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
+```
+
+# RxJava 2 Operators Examples present in this sample project:
+
+* `Map` -> transform the items emitted by an Observable by applying a function to each item
+* `Zip` -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
+* `Filter` -> emit only those items from an Observable that pass a predicate test
+* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable
+* `Take` -> emit only the first n items emitted by an Observable. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* `Reduce` -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
+* `Skip` -> suppress the first n items emitted by an Observable
+* `Buffer` -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
+* `Concat` -> emit the emissions from two or more Observables without interleaving them
+* `Replay` -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
+* `Merge` -> combine multiple Observables into one by merging their emissions
+* `SwitchMap` -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
+
+
+# Highlights of the examples :
+
+* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`
+* [FlowableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java) - Using `Flowable` and `reduce` operator
+* [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
+* [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`
+* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator
+* [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator
+* [BufferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java) - Using `buffer` Operator
+* [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* [ReduceExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java) - Using `reduce` Operator
+* [FilterExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java) - Using `filter` Operator
+* [SkipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java) - Using `skip` Operator
+* [ReplayExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java) - Using `replay` Operator
+* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator
+* [MergeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java) - Using `merge` Operator
+* [DeferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java) - Using `defer` Observable
+* [SwitchMapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SwitchMapExampleActivity.java) - Using `switchMap` Observable
+* [IntervalExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java) - Using `Interval`. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* [RxBusActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/rxbus/RxBusActivity.java) - RxBus, RxJava2Bus, EventBus, RxEventBus
+* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView
+* [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
+* [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`
+* [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`
+* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java)
+
+### Find this project useful ? :heart:
+* Support it by clicking the :star: button on the upper right of this page. :v:
+
+Thanks
+
+[**Amit Shekhar**](https://amitshekhar.me)
+
+You can connect with me on:
+
+- [Twitter](https://twitter.com/amitiitbhu)
+- [LinkedIn](https://www.linkedin.com/in/amit-shekhar-iitbhu)
+- [GitHub](https://github.com/amitshekhariitbhu)
+- [Facebook](https://www.facebook.com/amit.shekhar.iitbhu)
+
+[**Read all of my blogs here.**](https://amitshekhar.me/blog)
+
+### License
+```
+   Copyright (C) 2022 Amit Shekhar
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+```
+
+### Contributing to RxJava 2 Android Samples
+Just make pull request. You are in!
  

From 3652b494c249157a4da875846352ecc2d9177f28 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Mon, 3 Oct 2022 13:57:09 +0530
Subject: [PATCH 20/28] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 79aff5f..a31c1ec 100644
--- a/README.md
+++ b/README.md
@@ -41,7 +41,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 
 # Highlights of the examples :
 
-* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`
+* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`. [Blog for reference](https://amitshekhar.me/blog/dispose-vs-clear-compositedisposable-rxjava)
 * [FlowableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java) - Using `Flowable` and `reduce` operator
 * [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
 * [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`

From 05a5123c8ae5ca49bc26be8949cabc8c30e328e0 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 4 Oct 2022 18:44:23 +0530
Subject: [PATCH 21/28] Update README.md

---
 README.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/README.md b/README.md
index a31c1ec..500d726 100644
--- a/README.md
+++ b/README.md
@@ -33,7 +33,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 * `Reduce` -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
 * `Skip` -> suppress the first n items emitted by an Observable
 * `Buffer` -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
-* `Concat` -> emit the emissions from two or more Observables without interleaving them
+* `Concat` -> emit the emissions from two or more Observables without interleaving them. [Blog for reference](https://amitshekhar.me/blog/rxjava-concat-operator)
 * `Replay` -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
 * `Merge` -> combine multiple Observables into one by merging their emissions
 * `SwitchMap` -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
@@ -53,7 +53,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 * [FilterExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java) - Using `filter` Operator
 * [SkipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java) - Using `skip` Operator
 * [ReplayExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java) - Using `replay` Operator
-* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator
+* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator. [Blog for reference](https://amitshekhar.me/blog/rxjava-concat-operator)
 * [MergeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java) - Using `merge` Operator
 * [DeferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java) - Using `defer` Observable
 * [SwitchMapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SwitchMapExampleActivity.java) - Using `switchMap` Observable

From 60994e428577e8a4aef3bc445a120dda8c2dc2df Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 11 Oct 2022 11:49:53 +0530
Subject: [PATCH 22/28] Update README.md

---
 README.md | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/README.md b/README.md
index 500d726..c30894d 100644
--- a/README.md
+++ b/README.md
@@ -25,10 +25,10 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 
 # RxJava 2 Operators Examples present in this sample project:
 
-* `Map` -> transform the items emitted by an Observable by applying a function to each item
+* `Map` -> transform the items emitted by an Observable by applying a function to each item. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
 * `Zip` -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
 * `Filter` -> emit only those items from an Observable that pass a predicate test
-* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable
+* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
 * `Take` -> emit only the first n items emitted by an Observable. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
 * `Reduce` -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
 * `Skip` -> suppress the first n items emitted by an Observable
@@ -45,7 +45,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 * [FlowableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java) - Using `Flowable` and `reduce` operator
 * [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
 * [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`
-* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator
+* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
 * [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator
 * [BufferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java) - Using `buffer` Operator
 * [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)

From 0e1c933484d84ef62eacd26475b15939428f459f Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 11 Oct 2022 19:05:59 +0530
Subject: [PATCH 23/28] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index c30894d..8af27ca 100644
--- a/README.md
+++ b/README.md
@@ -59,7 +59,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 * [SwitchMapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SwitchMapExampleActivity.java) - Using `switchMap` Observable
 * [IntervalExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java) - Using `Interval`. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
 * [RxBusActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/rxbus/RxBusActivity.java) - RxBus, RxJava2Bus, EventBus, RxEventBus
-* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView
+* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView. Blog: [Pagination In RecyclerView Using RxJava Operators](https://amitshekhar.me/blog/pagination-in-recyclerview-using-rxjava-operators)
 * [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
 * [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`
 * [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`

From a7d4dc79e649c41734cb17cd2f8784d6b43badb3 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Wed, 9 Nov 2022 16:15:23 +0530
Subject: [PATCH 24/28] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 8af27ca..eceb305 100644
--- a/README.md
+++ b/README.md
@@ -63,7 +63,7 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 * [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
 * [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`
 * [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`
-* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java)
+* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java). Blog: [RxJava Subject - Publish, Replay, Behavior, and Async](https://amitshekhar.me/blog/rxjava-subject-publish-replay-behavior-async)
 
 ### Find this project useful ? :heart:
 * Support it by clicking the :star: button on the upper right of this page. :v:

From 32432ed7b3672a73e3a08116a34e3af7764fc55f Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Wed, 18 Jan 2023 13:42:31 +0530
Subject: [PATCH 25/28] Update README.md

---
 README.md | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/README.md b/README.md
index eceb305..fd6eca3 100644
--- a/README.md
+++ b/README.md
@@ -6,6 +6,17 @@
 * who is migrating to RxJava 2 
 * or just started with RxJava.
 
+## About me
+
+Hi, I am [**Amit Shekhar**](https://amitshekhar.me), I have mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.
+
+You can connect with me on:
+
+- [Twitter](https://twitter.com/amitiitbhu)
+- [YouTube](https://www.youtube.com/@amitshekhar)
+- [LinkedIn](https://www.linkedin.com/in/amit-shekhar-iitbhu)
+- [GitHub](https://github.com/amitshekhariitbhu)
+
 ## [My Personal Blog - amitshekhar.me](https://amitshekhar.me/blog) - High-quality content to learn Android concepts.
 
 ### Just Build the project and start learning RxJava by examples.

From a22bb87c2bb74e96bb096f07ad97f863e0c6c7c8 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Sun, 7 Jul 2024 09:33:27 +0530
Subject: [PATCH 26/28] Update README.md

---
 README.md | 33 +++++++++++++++++----------------
 1 file changed, 17 insertions(+), 16 deletions(-)

diff --git a/README.md b/README.md
index fd6eca3..7d13459 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@
 
 ## About me
 
-Hi, I am [**Amit Shekhar**](https://amitshekhar.me), I have mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.
+Hi, I am Amit Shekhar, Co-Founder @ [Outcome School](https://outcomeschool.com) • IIT 2010-14 • I have taught and mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.
 
 You can connect with me on:
 
@@ -17,7 +17,7 @@ You can connect with me on:
 - [LinkedIn](https://www.linkedin.com/in/amit-shekhar-iitbhu)
 - [GitHub](https://github.com/amitshekhariitbhu)
 
-## [My Personal Blog - amitshekhar.me](https://amitshekhar.me/blog) - High-quality content to learn Android concepts.
+## Join **Outcome School** and get high paying tech job: [Outcome School](https://outcomeschool.com)
 
 ### Just Build the project and start learning RxJava by examples.
 
@@ -36,15 +36,15 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 
 # RxJava 2 Operators Examples present in this sample project:
 
-* `Map` -> transform the items emitted by an Observable by applying a function to each item. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
+* `Map` -> transform the items emitted by an Observable by applying a function to each item. Blog: [RxJava Operator Map vs FlatMap](https://outcomeschool.com/blog/rxjava-map-vs-flatmap)
 * `Zip` -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
 * `Filter` -> emit only those items from an Observable that pass a predicate test
-* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
-* `Take` -> emit only the first n items emitted by an Observable. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* `FlatMap` -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable. Blog: [RxJava Operator Map vs FlatMap](https://outcomeschool.com/blog/rxjava-map-vs-flatmap)
+* `Take` -> emit only the first n items emitted by an Observable. [Blog for reference](https://outcomeschool.com/blog/rxjava-interval-operator)
 * `Reduce` -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
 * `Skip` -> suppress the first n items emitted by an Observable
 * `Buffer` -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
-* `Concat` -> emit the emissions from two or more Observables without interleaving them. [Blog for reference](https://amitshekhar.me/blog/rxjava-concat-operator)
+* `Concat` -> emit the emissions from two or more Observables without interleaving them. [Blog for reference](https://outcomeschool.com/blog/rxjava-concat-operator)
 * `Replay` -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
 * `Merge` -> combine multiple Observables into one by merging their emissions
 * `SwitchMap` -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable
@@ -52,36 +52,37 @@ compile 'io.reactivex.rxjava2:rxandroid:X.X.X'
 
 # Highlights of the examples :
 
-* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`. [Blog for reference](https://amitshekhar.me/blog/dispose-vs-clear-compositedisposable-rxjava)
+* [DisposableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DisposableExampleActivity.java) - Using `CompositeDisposable`. [Blog for reference](https://outcomeschool.com/blog/dispose-vs-clear-compositedisposable-rxjava)
 * [FlowableExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FlowableExampleActivity.java) - Using `Flowable` and `reduce` operator
 * [SingleObserverExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SingleObserverExampleActivity.java) - Using `SingleObserver`
 * [CompletableObserverActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/CompletableObserverExampleActivity.java) - Using `CompletableObserver`
-* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator. Blog: [RxJava Operator Map vs FlatMap](https://amitshekhar.me/blog/rxjava-map-vs-flatmap)
+* [MapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MapExampleActivity.java) - Using `map` Operator. Blog: [RxJava Operator Map vs FlatMap](https://outcomeschool.com/blog/rxjava-map-vs-flatmap)
 * [ZipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ZipExampleActivity.java) - Using `zip` Operator
 * [BufferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/BufferExampleActivity.java) - Using `buffer` Operator
-* [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* [TakeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/TakeExampleActivity.java) - Using `take` Operator. [Blog for reference](https://outcomeschool.com/blog/rxjava-interval-operator)
 * [ReduceExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReduceExampleActivity.java) - Using `reduce` Operator
 * [FilterExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/FilterExampleActivity.java) - Using `filter` Operator
 * [SkipExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SkipExampleActivity.java) - Using `skip` Operator
 * [ReplayExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ReplayExampleActivity.java) - Using `replay` Operator
-* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator. [Blog for reference](https://amitshekhar.me/blog/rxjava-concat-operator)
+* [ConcatExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/ConcatExampleActivity.java) - Using `concat` Operator. [Blog for reference](https://outcomeschool.com/blog/rxjava-concat-operator)
 * [MergeExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/MergeExampleActivity.java) - Using `merge` Operator
 * [DeferExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/DeferExampleActivity.java) - Using `defer` Observable
 * [SwitchMapExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/SwitchMapExampleActivity.java) - Using `switchMap` Observable
-* [IntervalExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java) - Using `Interval`. [Blog for reference](https://amitshekhar.me/blog/rxjava-interval-operator)
+* [IntervalExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/IntervalExampleActivity.java) - Using `Interval`. [Blog for reference](https://outcomeschool.com/blog/rxjava-interval-operator)
 * [RxBusActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/rxbus/RxBusActivity.java) - RxBus, RxJava2Bus, EventBus, RxEventBus
-* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView. Blog: [Pagination In RecyclerView Using RxJava Operators](https://amitshekhar.me/blog/pagination-in-recyclerview-using-rxjava-operators)
+* [PaginationActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/pagination/PaginationActivity.java) - Pagination for loadMore in RecyclerView. Blog: [Pagination In RecyclerView Using RxJava Operators](https://outcomeschool.com/blog/pagination-in-recyclerview-using-rxjava-operators)
 * [ComposeOperatorExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/compose/ComposeOperatorExampleActivity.java) - Compose operator for reusable
 * [Search Implementation](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/search/SearchActivity.java) - Using `debounce`, `switchMap`, `distinctUntilChanged`
 * [Implement Caching Using RxJava Operators](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/cache/CacheExampleActivity.java) - Using `concat`, `firstElement`
-* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java). Blog: [RxJava Subject - Publish, Replay, Behavior, and Async](https://amitshekhar.me/blog/rxjava-subject-publish-replay-behavior-async)
+* [PublishSubjectExampleActivity](https://github.com/amitshekhariitbhu/RxJava2-Android-Samples/blob/master/app/src/main/java/com/rxjava2/android/samples/ui/operators/PublishSubjectExampleActivity.java). Blog: [RxJava Subject - Publish, Replay, Behavior, and Async](https://outcomeschool.com/blog/rxjava-subject-publish-replay-behavior-async)
 
 ### Find this project useful ? :heart:
 * Support it by clicking the :star: button on the upper right of this page. :v:
 
 Thanks
 
-[**Amit Shekhar**](https://amitshekhar.me)
+**Amit Shekhar**\
+Co-Founder @ [Outcome School](https://outcomeschool.com)
 
 You can connect with me on:
 
@@ -90,11 +91,11 @@ You can connect with me on:
 - [GitHub](https://github.com/amitshekhariitbhu)
 - [Facebook](https://www.facebook.com/amit.shekhar.iitbhu)
 
-[**Read all of my blogs here.**](https://amitshekhar.me/blog)
+[**Read all of our blogs here.**](https://outcomeschool.com/blog)
 
 ### License
 ```
-   Copyright (C) 2022 Amit Shekhar
+   Copyright (C) 2024 Amit Shekhar
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.

From feaaf21a088d9cd732b21b2657b5df4676d74fd1 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Tue, 12 Aug 2025 21:43:15 +0530
Subject: [PATCH 27/28] Delete .github directory

---
 .github/FUNDING.yml | 13 -------------
 1 file changed, 13 deletions(-)
 delete mode 100644 .github/FUNDING.yml

diff --git a/.github/FUNDING.yml b/.github/FUNDING.yml
deleted file mode 100644
index 25c1f0e..0000000
--- a/.github/FUNDING.yml
+++ /dev/null
@@ -1,13 +0,0 @@
-# These are supported funding model platforms
-
-github: [amitshekhariitbhu]
-patreon: # Replace with a single Patreon username
-open_collective: # Replace with a single Open Collective username
-ko_fi: # Replace with a single Ko-fi username
-tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
-community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
-liberapay: # Replace with a single Liberapay username
-issuehunt: # Replace with a single IssueHunt username
-otechie: # Replace with a single Otechie username
-lfx_crowdfunding: # Replace with a single LFX Crowdfunding project-name e.g., cloud-foundry
-custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

From 74693e26ef44c59368b48a77d1600b1ff019b7a1 Mon Sep 17 00:00:00 2001
From: AMIT SHEKHAR <amit.shekhar.iitbhu@gmail.com>
Date: Wed, 28 Jan 2026 14:56:05 +0530
Subject: [PATCH 28/28] Update README.md

---
 README.md | 21 ++++++++++++++++-----
 1 file changed, 16 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index 7d13459..8aa4e01 100644
--- a/README.md
+++ b/README.md
@@ -8,16 +8,27 @@
 
 ## About me
 
-Hi, I am Amit Shekhar, Co-Founder @ [Outcome School](https://outcomeschool.com) • IIT 2010-14 • I have taught and mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.
+Hi, I am Amit Shekhar, Founder @ [Outcome School](https://outcomeschool.com) • IIT 2010-14 • I have taught and mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.
 
-You can connect with me on:
+### Follow Amit Shekhar
 
-- [Twitter](https://twitter.com/amitiitbhu)
-- [YouTube](https://www.youtube.com/@amitshekhar)
+- [X/Twitter](https://twitter.com/amitiitbhu)
 - [LinkedIn](https://www.linkedin.com/in/amit-shekhar-iitbhu)
 - [GitHub](https://github.com/amitshekhariitbhu)
 
-## Join **Outcome School** and get high paying tech job: [Outcome School](https://outcomeschool.com)
+### Follow Outcome School
+
+- [YouTube](https://youtube.com/@OutcomeSchool)
+- [X/Twitter](https://x.com/outcome_school)
+- [LinkedIn](https://www.linkedin.com/company/outcomeschool)
+- [GitHub](http://github.com/OutcomeSchool)
+
+## I teach at Outcome School
+
+- AI and Machine Learning
+- Android
+
+Join Outcome School and get a high-paying tech job: [Outcome School](https://outcomeschool.com)
 
 ### Just Build the project and start learning RxJava by examples.