spec-js/operators/sampleTime-spec.js

"use strict";
var Rx = require('../../dist/package/Rx');
var Observable = Rx.Observable;
/** @test {sampleTime} */
describe('Observable.prototype.sampleTime', function () {
    asDiagram('sampleTime(70)')('should get samples on a delay', function () {
        var e1 = hot('a---b-c---------d--e---f-g-h--|');
        var e1subs = '^                             !';
        var expected = '-------c-------------e------h-|';
        // timer          -------!------!------!------!--
        expectObservable(e1.sampleTime(70, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should sample nothing if new value has not arrived', function () {
        var e1 = hot('----a-^--b----c--------------f----|');
        var e1subs = '^                           !';
        var expected = '-----------c----------------|';
        // timer              -----------!----------!---------
        expectObservable(e1.sampleTime(110, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should sample if new value has arrived, even if it is the same value', function () {
        var e1 = hot('----a-^--b----c----------c---f----|');
        var e1subs = '^                           !';
        var expected = '-----------c----------c-----|';
        // timer              -----------!----------!---------
        expectObservable(e1.sampleTime(110, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should sample nothing if source has not nexted by time of sample', function () {
        var e1 = hot('----a-^-------------b-------------|');
        var e1subs = '^                           !';
        var expected = '----------------------b-----|';
        // timer              -----------!----------!---------
        expectObservable(e1.sampleTime(110, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should raise error if source raises error', function () {
        var e1 = hot('----a-^--b----c----d----#');
        var e1subs = '^                 !';
        var expected = '-----------c------#';
        // timer              -----------!----------!---------
        expectObservable(e1.sampleTime(110, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should allow unsubscribing explicitly and early', function () {
        var e1 = hot('----a-^--b----c----d----e----f----|');
        var unsub = '                !            ';
        var e1subs = '^               !            ';
        var expected = '-----------c-----            ';
        // timer              -----------!----------!---------
        expectObservable(e1.sampleTime(110, rxTestScheduler), unsub).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should not break unsubscription chains when result is unsubscribed explicitly', function () {
        var e1 = hot('----a-^--b----c----d----e----f----|');
        var e1subs = '^               !            ';
        // timer              -----------!----------!---------
        var expected = '-----------c-----            ';
        var unsub = '                !            ';
        var result = e1
            .mergeMap(function (x) { return Observable.of(x); })
            .sampleTime(110, rxTestScheduler)
            .mergeMap(function (x) { return Observable.of(x); });
        expectObservable(result, unsub).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should completes if source does not emits', function () {
        var e1 = cold('|');
        var e1subs = '(^!)';
        var expected = '|';
        expectObservable(e1.sampleTime(60, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should raise error if source throws immediately', function () {
        var e1 = cold('#');
        var e1subs = '(^!)';
        var expected = '#';
        expectObservable(e1.sampleTime(60, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
    it('should not completes if source does not complete', function () {
        var e1 = cold('-');
        var e1subs = '^';
        var expected = '-';
        expectObservable(e1.sampleTime(60, rxTestScheduler)).toBe(expected);
        expectSubscriptions(e1.subscriptions).toBe(e1subs);
    });
});
//# sourceMappingURL=sampleTime-spec.js.map