Merge pull request #38 from kwonoj/feat-advanceframe

feat(advanceto): implement advanceTo interface  …

spec/assert/constructObservableMarble-spec.ts

@@ -153,8 +153,8 @@ describe('constructObservableMarble', () => {
     expect(marble).to.equal(e);
   });
 
-  it('should craet marble with higher order obsrevables', () => {
-    const scheduler = new TestScheduler();
+  it('should create marble with higher order obsrevables', () => {
+    const scheduler = new TestScheduler(false, 1, 1000);
 
     const s = '--a--b--|';
     const a = scheduler.createHotObservable('--1--2--|');

spec/index-spec.ts

@@ -37,6 +37,16 @@ describe('rxSandbox', () => {
     expect(v).to.deep.equal(expected);
   });
 
+  it('should able to create instance with custom maxFrame', () => {
+    const sandbox = idx.rxSandbox;
+
+    const { e } = sandbox.create(false, 1, 5);
+    const v = e('--a------|');
+    const expected = [idx.next(2, 'a')];
+
+    expect(v).to.deep.equal(expected);
+  });
+
   it('should able to create expected message values', () => {
     const { e } = idx.rxSandbox.create();
 

spec/marbles/parseObservableMarble-spec.ts

@@ -27,6 +27,15 @@ describe('parseObservableMarble', () => {
     expect(messages).to.deep.equal(expected);
   });
 
+  it('should parse timeframe with maxFrame', () => {
+    const marble = '--a------b--|';
+
+    const messages = parseObservableMarble(marble, null, null, false, 1, 5);
+    const expected = [next(2, 'a')];
+
+    expect(messages).to.deep.equal(expected);
+  });
+
   it('should flatten custom value with inner observable when specified', () => {
     const marble = '----a--b--';
     const aMessages = [next(1, '1'), next(2, '2')];
@@ -68,6 +77,15 @@ describe('parseObservableMarble', () => {
     expect(messages).to.deep.equal(expected);
   });
 
+  it('should support custom timeframe value with maxFrame', () => {
+    const marble = '--a------b--|';
+
+    const messages = parseObservableMarble(marble, null, null, false, 10, 50);
+    const expected = [next(20, 'a')];
+
+    expect(messages).to.deep.equal(expected);
+  });
+
   it('should parse value literal', () => {
     const marble = 'x';
 
@@ -179,7 +197,7 @@ describe('parseObservableMarble', () => {
   });
 
   it('should able to flatten inner observable', () => {
-    const scheduler = new TestScheduler();
+    const scheduler = new TestScheduler(false, 1, 1000);
 
     const marble = '                            --a--|';
     const inner = scheduler.createColdObservable('---1--');

spec/marbles/parseSubscriptionMarble-spec.ts

@@ -30,6 +30,15 @@ describe('parseSubscriptionMarble', () => {
     expect(subscription).to.deep.equal(expected);
   });
 
+  it('should parse subscription with unsubscription with maxFrame', () => {
+    const marble = '--^-----!';
+
+    const subscription = parseSubscriptionMarble(marble, 1, 5);
+    const expected = subscribe(2, Number.POSITIVE_INFINITY);
+
+    expect(subscription).to.deep.equal(expected);
+  });
+
   it('should support custom timeframe value', () => {
     const marble = '--^-----!';
 
@@ -39,6 +48,15 @@ describe('parseSubscriptionMarble', () => {
     expect(subscription).to.deep.equal(expected);
   });
 
+  it('should support custom timeframe value with maxFrame', () => {
+    const marble = '--^-----!';
+
+    const subscription = parseSubscriptionMarble(marble, 10, 50);
+    const expected = subscribe(20, Number.POSITIVE_INFINITY);
+
+    expect(subscription).to.deep.equal(expected);
+  });
+
   it('should allow whitespace', () => {
     const marble = '-- ^   -----!';