JezK
Edit File: empty-spec.js
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); var chai_1 = require("chai"); var rxjs_1 = require("rxjs"); var testing_1 = require("rxjs/testing"); var observableMatcher_1 = require("../helpers/observableMatcher"); describe('empty', function () { var rxTestScheduler; beforeEach(function () { rxTestScheduler = new testing_1.TestScheduler(observableMatcher_1.observableMatcher); }); it('should return EMPTY', function () { (0, chai_1.expect)((0, rxjs_1.empty)()).to.equal(rxjs_1.EMPTY); }); it('should create a cold observable with only complete', function () { rxTestScheduler.run(function (_a) { var expectObservable = _a.expectObservable; var expected = '|'; var e1 = (0, rxjs_1.empty)(); expectObservable(e1).toBe(expected); }); }); it('should return the same instance EMPTY', function () { var s1 = (0, rxjs_1.empty)(); var s2 = (0, rxjs_1.empty)(); (0, chai_1.expect)(s1).to.equal(s2); }); it('should be synchronous by default', function () { var source = (0, rxjs_1.empty)(); var hit = false; source.subscribe({ complete: function () { hit = true; }, }); (0, chai_1.expect)(hit).to.be.true; }); it('should equal EMPTY', function () { (0, chai_1.expect)((0, rxjs_1.empty)()).to.equal(rxjs_1.EMPTY); }); it('should take a scheduler', function () { var source = (0, rxjs_1.empty)(rxTestScheduler); var hit = false; source.subscribe({ complete: function () { hit = true; }, }); (0, chai_1.expect)(hit).to.be.false; rxTestScheduler.flush(); (0, chai_1.expect)(hit).to.be.true; }); }); //# sourceMappingURL=empty-spec.js.map