JezK
Edit File: defaultIfEmpty-spec.js
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); var chai_1 = require("chai"); var observableMatcher_1 = require("../helpers/observableMatcher"); var rxjs_1 = require("rxjs"); var operators_1 = require("rxjs/operators"); var testing_1 = require("rxjs/testing"); describe('defaultIfEmpty', function () { var testScheduler; beforeEach(function () { testScheduler = new testing_1.TestScheduler(observableMatcher_1.observableMatcher); }); it('should return the Observable if not empty with a default value', function () { testScheduler.run(function (_a) { var hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = hot(' --------|'); var e1subs = ' ^-------!'; var expected = '--------(x|)'; expectObservable(e1.pipe((0, operators_1.defaultIfEmpty)(42))).toBe(expected, { x: 42 }); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should return the argument if Observable is empty', function () { testScheduler.run(function (_a) { var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = cold(' |'); var e1subs = ' (^!)'; var expected = '(x|)'; expectObservable(e1.pipe((0, operators_1.defaultIfEmpty)('x'))).toBe(expected); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should return the Observable if not empty with a default value', function () { testScheduler.run(function (_a) { var hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = hot(' --a--b--|'); var e1subs = ' ^-------!'; var expected = '--a--b--|'; expectObservable(e1.pipe((0, operators_1.defaultIfEmpty)('x'))).toBe(expected); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should allow undefined as a default value', function () { testScheduler.run(function (_a) { var hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = hot(' --------|'); var e1subs = ' ^-------!'; var expected = '--------(U|)'; expectObservable(e1.pipe((0, operators_1.defaultIfEmpty)(undefined))).toBe(expected, { U: undefined }); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should allow unsubscribing early and explicitly', function () { testScheduler.run(function (_a) { var hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = hot(' --a--b--|'); var e1subs = ' ^---! '; var expected = '--a-- '; var unsub = ' ----! '; var result = e1.pipe((0, operators_1.defaultIfEmpty)('x')); expectObservable(result, unsub).toBe(expected); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should not break unsubscription chains when unsubscribed explicitly', function () { testScheduler.run(function (_a) { var hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = hot(' --a--b--|'); var e1subs = ' ^---! '; var expected = '--a-- '; var unsub = ' ----! '; var result = e1.pipe((0, operators_1.mergeMap)(function (x) { return (0, rxjs_1.of)(x); }), (0, operators_1.defaultIfEmpty)('x'), (0, operators_1.mergeMap)(function (x) { return (0, rxjs_1.of)(x); })); expectObservable(result, unsub).toBe(expected); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should error if the Observable errors', function () { testScheduler.run(function (_a) { var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions; var e1 = cold(' #'); var e1subs = ' (^!)'; var expected = '#'; expectObservable(e1.pipe((0, operators_1.defaultIfEmpty)('x'))).toBe(expected); expectSubscriptions(e1.subscriptions).toBe(e1subs); }); }); it('should stop listening to a synchronous observable when unsubscribed', function () { var sideEffects = []; var synchronousObservable = new rxjs_1.Observable(function (subscriber) { for (var i = 0; !subscriber.closed && i < 10; i++) { sideEffects.push(i); subscriber.next(i); } }); synchronousObservable.pipe((0, operators_1.defaultIfEmpty)(0), (0, operators_1.take)(3)).subscribe(function () { }); (0, chai_1.expect)(sideEffects).to.deep.equal([0, 1, 2]); }); }); //# sourceMappingURL=defaultIfEmpty-spec.js.map