Add onErrroReturn

Author: amitshekhariitbhu

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);

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())