fix(VirtualTimeScheduler): remove default maxFrame limit

closes ReactiveX#1889
blakef · Aug 23, 2016 · 4c7eceb · 4c7eceb
1 parent 49c4b18
commit 4c7eceb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/scheduler/VirtualTimeScheduler.ts b/src/scheduler/VirtualTimeScheduler.ts
@@ -10,7 +10,7 @@ export class VirtualTimeScheduler extends AsyncScheduler {
   public index: number = -1;
 
   constructor(SchedulerAction: typeof AsyncAction = VirtualAction,
-              public maxFrames: number = 750) {
+              public maxFrames: number = Number.POSITIVE_INFINITY) {
     super(SchedulerAction, () => this.frame);
   }
 

diff --git a/src/testing/TestScheduler.ts b/src/testing/TestScheduler.ts
@@ -6,7 +6,9 @@ import {HotObservable} from './HotObservable';
 import {TestMessage} from './TestMessage';
 import {SubscriptionLog} from './SubscriptionLog';
 import {Subscription} from '../Subscription';
-import {VirtualTimeScheduler} from '../scheduler/VirtualTimeScheduler';
+import {VirtualTimeScheduler, VirtualAction} from '../scheduler/VirtualTimeScheduler';
+
+const defaultMaxFrame: number = 750;
 
 interface FlushableTest {
   ready: boolean;
@@ -23,7 +25,7 @@ export class TestScheduler extends VirtualTimeScheduler {
   private flushTests: FlushableTest[] = [];
 
   constructor(public assertDeepEqual: (actual: any, expected: any) => boolean | void) {
-    super();
+    super(VirtualAction, defaultMaxFrame);
   }
 
   createTime(marbles: string): number {