spec-js/Scheduler-spec.js

"use strict";
var chai_1 = require('chai');
var Rx = require('../dist/package/Rx');
var Scheduler = Rx.Scheduler;
/** @test {Scheduler} */
describe('Scheduler.queue', function () {
    it('should schedule things recursively', function () {
        var call1 = false;
        var call2 = false;
        Scheduler.queue.active = false;
        Scheduler.queue.schedule(function () {
            call1 = true;
            Scheduler.queue.schedule(function () {
                call2 = true;
            });
        });
        chai_1.expect(call1).to.be.true;
        chai_1.expect(call2).to.be.true;
    });
    it('should schedule things recursively via this.schedule', function () {
        var call1 = false;
        var call2 = false;
        Scheduler.queue.active = false;
        Scheduler.queue.schedule(function (state) {
            call1 = state.call1;
            call2 = state.call2;
            if (!call2) {
                this.schedule({ call1: true, call2: true });
            }
        }, 0, { call1: true, call2: false });
        chai_1.expect(call1).to.be.true;
        chai_1.expect(call2).to.be.true;
    });
    it('should schedule things in the future too', function (done) {
        var called = false;
        Scheduler.queue.schedule(function () {
            called = true;
        }, 60);
        setTimeout(function () {
            chai_1.expect(called).to.be.false;
        }, 20);
        setTimeout(function () {
            chai_1.expect(called).to.be.true;
            done();
        }, 100);
    });
    it('should be reusable after an error is thrown during execution', function (done) {
        var results = [];
        chai_1.expect(function () {
            Scheduler.queue.schedule(function () {
                results.push(1);
            });
            Scheduler.queue.schedule(function () {
                throw new Error('bad');
            });
        }).to.throw(Error, 'bad');
        setTimeout(function () {
            Scheduler.queue.schedule(function () {
                results.push(2);
                done();
            });
        }, 0);
    });
});
//# sourceMappingURL=Scheduler-spec.js.map