test(throttleTime): should handle busy producer with options '{ leadi…

…ng: true, trailing: true }'
ReactiveX · Jan 26, 2019 · 68245a0 · 68245a0
1 parent 0954f9f
commit 68245a0
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/spec/operators/throttleTime-spec.ts b/spec/operators/throttleTime-spec.ts
@@ -152,6 +152,15 @@ describe('throttleTime operator', () => {
       expectObservable(result).toBe(expected);
       expectSubscriptions(e1.subscriptions).toBe(e1subs);
     });
+    asDiagram('throttleTime(fn, { leading: true, trailing: true })')('should handle a busy producer emitting a regular repeating sequence', () =>  {
+      const e1 =   hot('abcdabcdabcdabcdabcd|');
+      const subs =     '^                   !';
+      const t =   time('----|               ');
+      const expected = 'a---a---a---a---a---(d|';
+
+      expectObservable(e1.pipe(throttleTime(t, rxTestScheduler, { leading: true, trailing: true }))).toBe(expected);
+      expectSubscriptions(e1.subscriptions).toBe(subs);
+    });
   });
 
   describe('throttleTime(fn, { leading: false, trailing: true })', () => {