diff --git a/app/src/main/java/org/schabi/newpipe/local/playlist/LocalPlaylistFragment.java b/app/src/main/java/org/schabi/newpipe/local/playlist/LocalPlaylistFragment.java
index 0881c6b97..8e8ad44ec 100644
--- a/app/src/main/java/org/schabi/newpipe/local/playlist/LocalPlaylistFragment.java
+++ b/app/src/main/java/org/schabi/newpipe/local/playlist/LocalPlaylistFragment.java
@@ -369,12 +369,11 @@ public class LocalPlaylistFragment extends BaseLocalListFragment<List<PlaylistSt
     }
 
     public void removeWatchedStreams() {
-        showLoading();
-
-        if (removeWatchedDisposable != null) {
-            // In case this is called twice
-            removeWatchedDisposable.dispose();
+        if (removeWatchedDisposable != null && !removeWatchedDisposable.isDisposed()) {
+            // already running
+            return;
         }
+        showLoading();
 
         removeWatchedDisposable = Flowable.just(
                 playlistManager.getPlaylistStreams(playlistId).blockingFirst())
@@ -431,8 +430,7 @@ public class LocalPlaylistFragment extends BaseLocalListFragment<List<PlaylistSt
                     }
 
                     hideLoading();
-                }, this::onError
-                );
+                }, this::onError);
     }
 
     @Override