diff --git a/src/internal/operators/debounceTime.ts b/src/internal/operators/debounceTime.ts index 78cd632c63e..02b87c8877d 100644 --- a/src/internal/operators/debounceTime.ts +++ b/src/internal/operators/debounceTime.ts @@ -85,7 +85,7 @@ export function debounceTime(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(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))); } }, () => {