prefsutil: fix subscription leak in recursion_guard()

ddterm · Oct 20, 2022 · 3ff04fb · 3ff04fb
1 parent e3462b0
commit 3ff04fb
Showing 1 changed file with 11 additions and 13 deletions.
diff --git a/prefsutil.js b/prefsutil.js
@@ -46,19 +46,17 @@ function recursion_guard() {
         if (!rxjs.isObservable(arg))
             return call(arg);
 
-        return new rxjs.Observable(subscriber => {
-            arg.subscribe({
-                next(value) {
-                    call(() => subscriber.next(value));
-                },
-                error(error) {
-                    subscriber.error(error);
-                },
-                complete() {
-                    subscriber.complete();
-                },
-            });
-        });
+        return new rxjs.Observable(subscriber => arg.subscribe({
+            next(value) {
+                call(() => subscriber.next(value));
+            },
+            error(error) {
+                subscriber.error(error);
+            },
+            complete() {
+                subscriber.complete();
+            },
+        }));
     };
 }