fix(debounceTime): unschedule dangling task on unsubscribe before com…

…plete
ReactiveX · Jun 10, 2021 · 4c7deff · 4c7deff
1 parent 4f4ac00
commit 4c7deff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/internal/operators/debounceTime.ts b/src/internal/operators/debounceTime.ts
@@ -85,7 +85,7 @@ export function debounceTime<T>(dueTime: number, scheduler: SchedulerLike = asyn
       const now = scheduler.now();
       if (now < targetTime) {
         // On that case, re-schedule to the new target
-        activeTask = this.schedule(undefined, targetTime - now);
+        subscriber.add((activeTask = this.schedule(undefined, targetTime - now)));
         return;
       }
 
@@ -101,7 +101,7 @@ export function debounceTime<T>(dueTime: number, scheduler: SchedulerLike = asyn
 
           // Only set up a task if it's not already up
           if (!activeTask) {
-            activeTask = scheduler.schedule(emitWhenIdle, dueTime);
+            subscriber.add((activeTask = scheduler.schedule(emitWhenIdle, dueTime)));
           }
         },
         () => {