fix(throttleTime): feedback from @Parakleta - schedule timer before e…

…mitting value
ReactiveX · Sep 26, 2017 · 9cda512 · 9cda512
1 parent ade1c0e
commit 9cda512
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/operators/throttleTime.ts b/src/operators/throttleTime.ts
@@ -86,6 +86,7 @@ class ThrottleTimeSubscriber<T> extends Subscriber<T> {
 
   protected _next(value: T) {
     if (!this.throttled && this.leading) {
+      this.throttle();
       this.destination.next(value);
     } else if (this.trailing) {
       this._trailingValue = value;
@@ -110,10 +111,11 @@ class ThrottleTimeSubscriber<T> extends Subscriber<T> {
       this.throttled = null;
 
       if (this.trailing && this._hasTrailingValue) {
-        this.destination.next(this._trailingValue);
+        const trailingValue = this._trailingValue;
         this._trailingValue = null;
         this._hasTrailingValue = false;
         this.throttle();
+        this.destination.next(trailingValue);
       }
     }
   }