spec-js/Subscriber-spec.js

"use strict";
var chai_1 = require('chai');
var sinon = require('sinon');
var Rx = require('../dist/package/Rx');
var Subscriber = Rx.Subscriber;
/** @test {Subscriber} */
describe('Subscriber', function () {
    describe('when created through create()', function () {
        it('should not call error() if next() handler throws an error', function () {
            var errorSpy = sinon.spy();
            var completeSpy = sinon.spy();
            var subscriber = Subscriber.create(function (value) {
                if (value === 2) {
                    throw 'error!';
                }
            }, errorSpy, completeSpy);
            subscriber.next(1);
            chai_1.expect(function () {
                subscriber.next(2);
            }).to.throw('error!');
            chai_1.expect(errorSpy).not.have.been.called;
            chai_1.expect(completeSpy).not.have.been.called;
        });
    });
    it('should ignore next messages after unsubscription', function () {
        var times = 0;
        var sub = new Subscriber({
            next: function () { times += 1; }
        });
        sub.next();
        sub.next();
        sub.unsubscribe();
        sub.next();
        chai_1.expect(times).to.equal(2);
    });
    it('should ignore error messages after unsubscription', function () {
        var times = 0;
        var errorCalled = false;
        var sub = new Subscriber({
            next: function () { times += 1; },
            error: function () { errorCalled = true; }
        });
        sub.next();
        sub.next();
        sub.unsubscribe();
        sub.next();
        sub.error();
        chai_1.expect(times).to.equal(2);
        chai_1.expect(errorCalled).to.be.false;
    });
    it('should ignore complete messages after unsubscription', function () {
        var times = 0;
        var completeCalled = false;
        var sub = new Subscriber({
            next: function () { times += 1; },
            complete: function () { completeCalled = true; }
        });
        sub.next();
        sub.next();
        sub.unsubscribe();
        sub.next();
        sub.complete();
        chai_1.expect(times).to.equal(2);
        chai_1.expect(completeCalled).to.be.false;
    });
    it('should not be closed when other subscriber with same observer instance completes', function () {
        var observer = {
            next: function () { }
        };
        var sub1 = new Subscriber(observer);
        var sub2 = new Subscriber(observer);
        sub2.complete();
        chai_1.expect(sub1.closed).to.be.false;
        chai_1.expect(sub2.closed).to.be.true;
    });
    it('should call complete observer without any arguments', function () {
        var argument = null;
        var observer = {
            complete: function () {
                var args = [];
                for (var _i = 0; _i < arguments.length; _i++) {
                    args[_i - 0] = arguments[_i];
                }
                argument = args;
            }
        };
        var sub1 = new Subscriber(observer);
        sub1.complete();
        chai_1.expect(argument).to.have.lengthOf(0);
    });
});
//# sourceMappingURL=Subscriber-spec.js.map