1 files changed, 6 insertions, 10 deletions
diff --git a/app/src/main/java/de/danoeh/antennapod/dialog/RemoveFeedDialog.java b/app/src/main/java/de/danoeh/antennapod/dialog/RemoveFeedDialog.java
index 9fcf8be69..23c032248 100644
--- a/app/src/main/java/de/danoeh/antennapod/dialog/RemoveFeedDialog.java
+++ b/app/src/main/java/de/danoeh/antennapod/dialog/RemoveFeedDialog.java
@@ -19,18 +19,18 @@ import io.reactivex.schedulers.Schedulers;
 public class RemoveFeedDialog {
     private static final String TAG = "RemoveFeedDialog";
 
-    public static void show(Context context, Feed feed, Runnable onSuccess) {
+    public static void show(Context context, Feed feed) {
         List<Feed> feeds = Collections.singletonList(feed);
         String message = getMessageId(context, feeds);
-        showDialog(context, feeds, message, onSuccess);
+        showDialog(context, feeds, message);
     }
 
-    public static void show(Context context, List<Feed> feeds, Runnable onSuccess) {
+    public static void show(Context context, List<Feed> feeds) {
         String message = getMessageId(context, feeds);
-        showDialog(context, feeds, message, onSuccess);
+        showDialog(context, feeds, message);
     }
 
-    private static void showDialog(Context context, List<Feed> feeds, String message, Runnable onSuccess) {
+    private static void showDialog(Context context, List<Feed> feeds, String message) {
         ConfirmationDialog dialog = new ConfirmationDialog(context, R.string.remove_feed_label, message) {
             @Override
             public void onConfirmButtonPressed(DialogInterface clickedDialog) {
@@ -42,20 +42,16 @@ public class RemoveFeedDialog {
                 progressDialog.setCancelable(false);
                 progressDialog.show();
 
-                Completable.fromCallable(() -> {
+                Completable.fromAction(() -> {
                     for (Feed feed : feeds) {
                         DBWriter.deleteFeed(context, feed.getId()).get();
                     }
-                    return null;
                 })
                         .subscribeOn(Schedulers.io())
                         .observeOn(AndroidSchedulers.mainThread())
                         .subscribe(
                             () -> {
                                 Log.d(TAG, "Feed(s) deleted");
-                                if (onSuccess != null) {
-                                    onSuccess.run();
-                                }
                                 progressDialog.dismiss();
                             }, error -> {
                                 Log.e(TAG, Log.getStackTraceString(error));