JezK

Edit File: shareReplay-spec.js

"use strict";
var __extends = (this && this.__extends) || (function () {
    var extendStatics = function (d, b) {
        extendStatics = Object.setPrototypeOf ||
            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
        return extendStatics(d, b);
    };
    return function (d, b) {
        if (typeof b !== "function" && b !== null)
            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
        extendStatics(d, b);
        function __() { this.constructor = d; }
        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
    };
})();
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
var __generator = (this && this.__generator) || function (thisArg, body) {
    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
    function verb(n) { return function (v) { return step([n, v]); }; }
    function step(op) {
        if (f) throw new TypeError("Generator is already executing.");
        while (_) try {
            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
            if (y = 0, t) op = [op[0] & 2, t.value];
            switch (op[0]) {
                case 0: case 1: t = op; break;
                case 4: _.label++; return { value: op[1], done: false };
                case 5: _.label++; y = op[1]; op = [0]; continue;
                case 7: op = _.ops.pop(); _.trys.pop(); continue;
                default:
                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
                    if (t[2]) _.ops.pop();
                    _.trys.pop(); continue;
            }
            op = body.call(thisArg, _);
        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
    }
};
Object.defineProperty(exports, "__esModule", { value: true });
var chai_1 = require("chai");
var sinon = require("sinon");
var operators_1 = require("rxjs/operators");
var testing_1 = require("rxjs/testing");
var rxjs_1 = require("rxjs");
var observableMatcher_1 = require("../helpers/observableMatcher");
describe('shareReplay', function () {
    var testScheduler;
    beforeEach(function () {
        testScheduler = new testing_1.TestScheduler(observableMatcher_1.observableMatcher);
    });
    it('should mirror a simple source Observable', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('--1-2---3-4--5-|');
            var sourceSubs = ' ^--------------!';
            var expected = '   --1-2---3-4--5-|';
            var published = source.pipe((0, operators_1.shareReplay)());
            expectObservable(published).toBe(expected);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should do nothing if result is not subscribed', function () {
        var subscribed = false;
        var source = new rxjs_1.Observable(function () {
            subscribed = true;
        });
        source.pipe((0, operators_1.shareReplay)());
        (0, chai_1.expect)(subscribed).to.be.false;
    });
    it('should multicast the same values to multiple observers, bufferSize=1', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('    -1-2-3----4-|');
            var sourceSubs = '     ^-----------!';
            var subscriber1 = hot('a|           ');
            var expected1 = '      -1-2-3----4-|';
            var subscriber2 = hot('----b|       ');
            var expected2 = '      ----23----4-|';
            var subscriber3 = hot('--------c|   ');
            var expected3 = '      --------3-4-|';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should multicast the same values to multiple observers, bufferSize=2', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('    -1-2-----3------4-|');
            var sourceSubs = '     ^-----------------!';
            var subscriber1 = hot('a|                 ');
            var expected1 = '      -1-2-----3------4-|';
            var subscriber2 = hot('----b|             ');
            var expected2 = '      ----(12)-3------4-|';
            var subscriber3 = hot('-----------c|      ');
            var expected3 = '      -----------(23)-4-|';
            var shared = source.pipe((0, operators_1.shareReplay)(2));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should multicast an error from the source to multiple observers', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('    -1-2-3----4-#');
            var sourceSubs = '     ^-----------!';
            var subscriber1 = hot('a|           ');
            var expected1 = '      -1-2-3----4-#';
            var subscriber2 = hot('----b|       ');
            var expected2 = '      ----23----4-#';
            var subscriber3 = hot('--------c|   ');
            var expected3 = '      --------3-4-#';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should multicast an empty source', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('|   ');
            var sourceSubs = ' (^!)';
            var expected = '   |   ';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(shared).toBe(expected);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should multicast a never source', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('-');
            var sourceSubs = ' ^';
            var expected = '   -';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(shared).toBe(expected);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should multicast a throw source', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('#   ');
            var sourceSubs = ' (^!)';
            var expected = '   #   ';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(shared).toBe(expected);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should replay results to subsequent subscriptions if source completes, bufferSize=2', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('    -1-2-----3-|        ');
            var sourceSubs = '     ^----------!        ';
            var subscriber1 = hot('a|                  ');
            var expected1 = '      -1-2-----3-|        ';
            var subscriber2 = hot('----b|              ');
            var expected2 = '      ----(12)-3-|        ';
            var subscriber3 = hot('---------------(c|) ');
            var expected3 = '      ---------------(23|)';
            var shared = source.pipe((0, operators_1.shareReplay)(2));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should completely restart for subsequent subscriptions if source errors, bufferSize=2', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('    -1-2-----3-#               ');
            var sourceSubs1 = '    ^----------!               ';
            var subscriber1 = hot('a|                         ');
            var expected1 = '      -1-2-----3-#               ';
            var subscriber2 = hot('----b|                     ');
            var expected2 = '      ----(12)-3-#               ';
            var subscriber3 = hot('---------------(c|)        ');
            var expected3 = '      ----------------1-2-----3-#';
            var sourceSubs2 = '    ---------------^----------!';
            var shared = source.pipe((0, operators_1.shareReplay)(2));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe([sourceSubs1, sourceSubs2]);
        });
    });
    it('should be retryable, bufferSize=2', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, hot = _a.hot, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var subs = [];
            var source = cold('    -1-2-----3-#                      ');
            subs.push('              ^----------!                      ');
            subs.push('              -----------^----------!           ');
            subs.push('              ----------------------^----------!');
            var subscriber1 = hot('a|                                ');
            var expected1 = '      -1-2-----3--1-2-----3-#           ';
            var subscriber2 = hot('----b|                            ');
            var expected2 = '      ----(12)-3--1-2-----3-#           ';
            var subscriber3 = hot('---------------(c|)               ');
            var expected3 = '      ---------------(12)-3--1-2-----3-#';
            var shared = source.pipe((0, operators_1.shareReplay)(2), (0, operators_1.retry)(1));
            expectObservable(subscriber1.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected1);
            expectObservable(subscriber2.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected2);
            expectObservable(subscriber3.pipe((0, operators_1.mergeMapTo)(shared))).toBe(expected3);
            expectSubscriptions(source.subscriptions).toBe(subs);
        });
    });
    it('when no windowTime is given ReplaySubject should be in _infiniteTimeWindow mode', function () {
        var spy = sinon.spy(testScheduler, 'now');
        (0, rxjs_1.of)(1).pipe((0, operators_1.shareReplay)(1, undefined, testScheduler)).subscribe();
        spy.restore();
        (0, chai_1.expect)(spy, 'ReplaySubject should not call scheduler.now() when no windowTime is given').to.be.not.called;
    });
    it('should not restart due to unsubscriptions if refCount is false', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('a-b-c-d-e-f-g-h-i-j');
            var sourceSubs = ' ^------------------';
            var sub1 = '       ^------!           ';
            var expected1 = '  a-b-c-d-           ';
            var sub2 = '       -----------^-------';
            var expected2 = '  -----------fg-h-i-j';
            var shared = source.pipe((0, operators_1.shareReplay)({ bufferSize: 1, refCount: false }));
            expectObservable(shared, sub1).toBe(expected1);
            expectObservable(shared, sub2).toBe(expected2);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should restart due to unsubscriptions if refCount is true', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var sourceSubs = [];
            var source = cold('a-b-c-d-e-f-g-h-i-j           ');
            sourceSubs.push('    ^------!----------------------');
            sourceSubs.push('    -----------^------------------');
            var sub1 = '       ^------!                      ';
            var expected1 = '  a-b-c-d-                      ';
            var sub2 = '       -----------^------------------';
            var expected2 = '  -----------a-b-c-d-e-f-g-h-i-j';
            var shared = source.pipe((0, operators_1.shareReplay)({ bufferSize: 1, refCount: true }));
            expectObservable(shared, sub1).toBe(expected1);
            expectObservable(shared, sub2).toBe(expected2);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should not restart due to unsubscriptions if refCount is true when the source has completed', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('a-(b|)         ');
            var sourceSubs = ' ^-!            ';
            var sub1 = '       ^------!       ';
            var expected1 = '  a-(b|)         ';
            var sub2 = '       -----------^!  ';
            var expected2 = '  -----------(b|)';
            var shared = source.pipe((0, operators_1.shareReplay)({ bufferSize: 1, refCount: true }));
            expectObservable(shared, sub1).toBe(expected1);
            expectObservable(shared, sub2).toBe(expected2);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should not restart a synchronous source due to unsubscriptions if refCount is true when the source has completed', function () {
        var subscriptions = 0;
        var source = (0, rxjs_1.defer)(function () {
            ++subscriptions;
            return (0, rxjs_1.of)(42);
        }).pipe((0, operators_1.shareReplay)({ bufferSize: 1, refCount: true }));
        source.subscribe();
        source.subscribe();
        (0, chai_1.expect)(subscriptions).to.equal(1);
    });
    it('should only subscribe once each with multiple synchronous subscriptions and unsubscriptions ', function () { return __awaiter(void 0, void 0, void 0, function () {
        var subscriptions, source;
        return __generator(this, function (_a) {
            switch (_a.label) {
                case 0:
                    subscriptions = 0;
                    source = (0, rxjs_1.defer)(function () {
                        ++subscriptions;
                        return new rxjs_1.BehaviorSubject(1);
                    }).pipe((0, operators_1.shareReplay)({ bufferSize: 1, refCount: true }));
                    return [4, (0, rxjs_1.firstValueFrom)((0, rxjs_1.combineLatest)([source, source]))];
                case 1:
                    _a.sent();
                    (0, chai_1.expect)(subscriptions).to.equal(1);
                    return [2];
            }
        });
    }); });
    it('should default to refCount being false', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source = cold('a-b-c-d-e-f-g-h-i-j');
            var sourceSubs = ' ^------------------';
            var sub1 = '       ^------!           ';
            var expected1 = '  a-b-c-d-           ';
            var sub2 = '       -----------^-------';
            var expected2 = '  -----------fg-h-i-j';
            var shared = source.pipe((0, operators_1.shareReplay)(1));
            expectObservable(shared, sub1).toBe(expected1);
            expectObservable(shared, sub2).toBe(expected2);
            expectSubscriptions(source.subscriptions).toBe(sourceSubs);
        });
    });
    it('should not break lift() composability', function (done) {
        var MyCustomObservable = (function (_super) {
            __extends(MyCustomObservable, _super);
            function MyCustomObservable() {
                return _super !== null && _super.apply(this, arguments) || this;
            }
            MyCustomObservable.prototype.lift = function (operator) {
                var observable = new MyCustomObservable();
                observable.source = this;
                observable.operator = operator;
                return observable;
            };
            return MyCustomObservable;
        }(rxjs_1.Observable));
        var result = new MyCustomObservable(function (observer) {
            observer.next(1);
            observer.next(2);
            observer.next(3);
            observer.complete();
        }).pipe((0, operators_1.shareReplay)());
        (0, chai_1.expect)(result instanceof MyCustomObservable).to.be.true;
        var expected = [1, 2, 3];
        result.subscribe({
            next: function (n) {
                (0, chai_1.expect)(expected.length).to.be.greaterThan(0);
                (0, chai_1.expect)(n).to.equal(expected.shift());
            },
            error: function () {
                done(new Error('should not be called'));
            },
            complete: function () {
                done();
            },
        });
    });
    it('should not skip values on a sync source', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable;
            var a = (0, rxjs_1.from)(['a', 'b', 'c', 'd']);
            var x = cold('  x-------x');
            var expected = '(abcd)--d';
            var shared = a.pipe((0, operators_1.shareReplay)(1));
            var result = x.pipe((0, operators_1.mergeMapTo)(shared));
            expectObservable(result).toBe(expected);
        });
    });
    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.shareReplay)({ refCount: true }), (0, operators_1.take)(3)).subscribe(function () {
        });
        (0, chai_1.expect)(sideEffects).to.deep.equal([0, 1, 2]);
    });
    var FinalizationRegistry = global.FinalizationRegistry;
    if (FinalizationRegistry && global.gc) {
        it('should not leak the subscriber for sync sources', function (done) {
            var _a;
            var callback = function () {
            };
            var registry = new FinalizationRegistry(function (value) {
                (0, chai_1.expect)(value).to.equal('callback');
                done();
            });
            registry.register(callback, 'callback');
            var shared = (0, rxjs_1.of)(42).pipe((0, operators_1.shareReplay)(1));
            shared.subscribe(callback);
            callback = undefined;
            (_a = global.gc) === null || _a === void 0 ? void 0 : _a.call(global);
        });
    }
    else {
        console.warn("No support for FinalizationRegistry in Node ".concat(process.version));
    }
    it('should be referentially-transparent', function () {
        testScheduler.run(function (_a) {
            var cold = _a.cold, expectObservable = _a.expectObservable, expectSubscriptions = _a.expectSubscriptions;
            var source1 = cold('-1-2-3-4-5-|');
            var source1Subs = ' ^----------!';
            var expected1 = '   -1-2-3-4-5-|';
            var source2 = cold('-6-7-8-9-0-|');
            var source2Subs = ' ^----------!';
            var expected2 = '   -6-7-8-9-0-|';
            var partialPipeLine = (0, rxjs_1.pipe)((0, operators_1.shareReplay)({ refCount: false }));
            var shared1 = source1.pipe(partialPipeLine);
            var shared2 = source2.pipe(partialPipeLine);
            expectObservable(shared1).toBe(expected1);
            expectSubscriptions(source1.subscriptions).toBe(source1Subs);
            expectObservable(shared2).toBe(expected2);
            expectSubscriptions(source2.subscriptions).toBe(source2Subs);
        });
    });
});
//# sourceMappingURL=shareReplay-spec.js.map

Fairnetzt-Hochrhein | Vernetzung . Nachhaltigkeit . Gemeinschaft

VERNETZUNG

NACHHALTIGKEIT

GEMEINSCHAFT

VERANTWORTUNG

Willkommen auf Fairnetzt-Hochrhein,

Auf beiden Seiten der Rheingrenze gibt es viele Initiativen, Organisationen, Vereine und auch engagierte Einzelpersonen, welche sich für eine nachhaltige, lebenswerte Zukunft in unserer Region und darüber hinaus einsetzen.

Mit Fairnetzt-Hochrhein.de wollen wir eine Plattform bieten, welche auf lebendige und unkomplizierte Weise es Gruppen aus dem Landkreis Waldshut und aus den Kantonen Aargau und Schaffhausen ermöglicht, Veranstaltungen zu veröffentlichen und andererseits interessierte Menschen erfahren können, was wo stattfindet.

Wir wünschen Euch und uns allen
Ein Gutes Leben und Freude am Abenteuer der Mitgestaltung unserer eigenen Zukunft.

Das Redaktionsteam von Fairnetzt Hochrhein

Direktlink zu: Ihre Veranstaltungen einstellen? oder Anmeldung zum Newsletter?

Veranstaltungen

Dritter Nachhaltigkeitsstammtisch in Dogern

Ziel der Treffen ist, miteinander und voneinander zu lernen, wie man sich in verschiedenen Alltagsbereichen nachhaltiger verhalten kann:
• Einkauf von Dingen des täglichen und langfristigen Bedarfs
• Essen
• Energie sparen und erzeugen
• Unterwegs sein und Reisen, Mobilität
• Informationsaustausch
• …………
Jede*r ist willkommen, sich mit seinen und ihren Fragen und Erfahrungen einzubringen.
Grundidee: wir sind alle in bestimmten Lebensbereichen „Expert*innen“ und können so andere mit unserem Wissen bereichern und bei der Umsetzung im Alltag unterstützen.