test(window): add marble tests for window operator

ReactiveX · Oct 13, 2015 · 388944d · 388944d
1 parent be097b4
commit 388944d
Showing 1 changed file with 153 additions and 0 deletions.
diff --git a/spec/operators/window-spec.js b/spec/operators/window-spec.js
@@ -10,4 +10,157 @@ describe('Observable.prototype.window', function () {
     expectObservable(source.window(Observable.interval(130, rxTestScheduler)).mergeMap(function (x) { return x.toArray(); }))
       .toBe(expected, {x: ['a','b','c'], y: ['d','e','f'], z: ['g','h','i'] });
   });
+
+  it('should return a single empty window if source is empty and closings are basic', function () {
+    var source =   cold('|');
+    var closings = cold('--x--x--|');
+    var expected =      '(w|)';
+    var w =         cold('|');
+    var expectedValues = { w: w };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should return a single empty window if source is empty and closing is empty', function () {
+    var source =   cold('|');
+    var closings = cold('|');
+    var expected =      '(w|)';
+    var w =         cold('|');
+    var expectedValues = { w: w };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should split a Just source into a single window identical to source, using a Never closing',
+  function () {
+    var source =   cold('(a|)');
+    var closings = cold('-');
+    var expected =      '(w|)';
+    var w =         cold('(a|)');
+    var expectedValues = { w: w };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should return a single Never window if source is Never', function () {
+    var source =   cold('------');
+    var closings = cold('------');
+    var expected =      'w-----';
+    var w =        cold('------');
+    var expectedValues = { w: w };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should be able to split a never Observable into timely empty windows', function () {
+    var source =    hot('^--------');
+    var closings = cold('--x--x--|');
+    var expected =      'a-b--c--|';
+    var a =        cold('--|      ');
+    var b =        cold(  '---|   ');
+    var c =        cold(     '---|');
+    var expectedValues = { a: a, b: b, c: c };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should emit an error-only window if outer is a simple throw-Observable', function () {
+    var source =   cold('#');
+    var closings = cold('--x--x--|');
+    var expected =      '(w#)';
+    var w =         cold('#');
+    var expectedValues = { w: w };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+  });
+
+  it('should handle basic case with window closings', function () {
+    var source = hot('-1-2-^3-4-5-6-7-8-9-|         ');
+    var subs =            '^              !         ';
+    var closings = hot('---^---x---x---x---x---x---|');
+    var expected =        'a---b---c---d--|         ';
+    var a = cold(         '-3-4|                    ');
+    var b = cold(             '-5-6|                ');
+    var c = cold(                 '-7-8|            ');
+    var d = cold(                     '-9-|         ');
+    var expectedValues = { a: a, b: b, c: c, d: d };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+    expectSubscriptions(source.subscriptions).toBe(subs);
+  });
+
+  it('should handle basic case with window closings, but outer throws', function () {
+    var source = hot('-1-2-^3-4-5-6-7-8-9-#         ');
+    var subs =            '^              !         ';
+    var closings = hot('---^---x---x---x---x---x---|');
+    var expected =        'a---b---c---d--#         ';
+    var a = cold(         '-3-4|                    ');
+    var b = cold(             '-5-6|                ');
+    var c = cold(                 '-7-8|            ');
+    var d = cold(                     '-9-#         ');
+    var expectedValues = { a: a, b: b, c: c, d: d };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+    expectSubscriptions(source.subscriptions).toBe(subs);
+  });
+
+  it('should stop emitting windows when outer is unsubscribed early', function () {
+    var source = hot('-1-2-^3-4-5-6-7-8-9-|         ');
+    var unsub =           '        !                ';
+    var closings = hot('---^---x---x---x---x---x---|');
+    var expected =        'a---b----                ';
+    var a = cold(         '-3-4|                    ');
+    var b = cold(             '-5-6                 ');
+    var expectedValues = { a: a, b: b };
+
+    var result = source.window(closings);
+
+    expectObservable(result, unsub).toBe(expected, expectedValues);
+  });
+
+  it('should make outer emit error when closing throws', function () {
+    var source = hot('-1-2-^3-4-5-6-7-8-9-#         ');
+    var subs =            '^   !                    ';
+    var closings = hot('---^---#                    ');
+    var expected =        'a---#                    ';
+    var a = cold(         '-3-4#                    ');
+    var expectedValues = { a: a };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+    expectSubscriptions(source.subscriptions).toBe(subs);
+  });
+
+  it('should complete the resulting Observable when window closings completes', function () {
+    var source = hot('-1-2-^3-4-5-6-7-8-9-|         ');
+    var subs =            '^           !            ';
+    var closings = hot('---^---x---x---|            ');
+    var expected =        'a---b---c---|            ';
+    var a = cold(         '-3-4|                    ');
+    var b = cold(             '-5-6|                ');
+    var c = cold(                 '-7-8|            ');
+    var expectedValues = { a: a, b: b, c: c };
+
+    var result = source.window(closings);
+
+    expectObservable(result).toBe(expected, expectedValues);
+    expectSubscriptions(source.subscriptions).toBe(subs);
+  });
 });