fix(delay): fix memory leak

ReactiveX · Apr 29, 2018 · 0ced8f3 · 0ced8f3
1 parent 60e7521
commit 0ced8f3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/internal/operators/delay.ts b/src/internal/operators/delay.ts
@@ -92,6 +92,7 @@ class DelaySubscriber<T> extends Subscriber<T> {
       const delay = Math.max(0, queue[0].time - scheduler.now());
       this.schedule(state, delay);
     } else {
+      source.remove(this);
       source.active = false;
     }
   }