enome/lib/reactive-collection.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const rxjs_1 = require("rxjs");
const index_1 = require("./index");
const _ = require("lodash");
class ReactiveCollection {
    constructor(value = []) {
        this.pushed = new rxjs_1.ReplaySubject(1);
        this.popped = new rxjs_1.ReplaySubject(1);
        this.shifted = new rxjs_1.ReplaySubject(1);
        this.unshifted = new rxjs_1.ReplaySubject(1);
        this.removed = new rxjs_1.ReplaySubject(1);
        this.rotated = new rxjs_1.ReplaySubject(1);
        this.array = new index_1.ReactiveProperty(value);
        this.subs = [
            this.subscribeToPush(pushed => {
                const v = this.value;
                v.push(pushed);
                this.value = v;
            }),
            this.subscribeToUnshift(unshifted => {
                const v = this.value;
                v.unshift(unshifted);
                this.value = v;
            }),
        ];
    }
    get value() {
        return this.array.value;
    }
    set value(value) {
        this.array.value = value;
    }
    dispose() {
        this.subs.forEach(sub => sub.unsubscribe());
    }
    subscribeToPush(observer) {
        return this.pushed
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    subscribeToPop(observer) {
        return this.popped
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    subscribeToShift(observer) {
        return this.shifted
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    subscribeToUnshift(observer) {
        return this.unshifted
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    subscribeToRemove(observer) {
        return this.removed
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    subscribeToRotate(observer) {
        return this.rotated
            .observeOn(rxjs_1.Scheduler.asap)
            .subscribeOn(rxjs_1.Scheduler.asap)
            .subscribe(observer);
    }
    push(value) {
        this.pushed.next(value);
        return this;
    }
    pop(value) {
        const v = this.value;
        const popped = v.pop();
        this.popped.next(popped);
        this.value = v;
        return popped;
    }
    shift() {
        const v = this.value;
        const shifted = v.shift();
        this.shifted.next(shifted);
        this.value = v;
        return shifted;
    }
    unshift(value) {
        this.unshifted.next(value);
        return this;
    }
    remove(value) {
        const v = this.value;
        const removed = v.splice(v.indexOf(value));
        this.value = v;
        this.removed.next(removed[0]);
        return this;
    }
    rotate() {
        const value = this.value;
        const shifted = value.shift();
        value.push(shifted);
        this.rotated.next(shifted);
        this.value = value;
        return shifted;
    }
    rotateEach(action) {
        _.range(this.value.length).forEach(i => {
            action(this.rotate());
        });
    }
    mapCollection(selector) {
        return new ReactiveCollection(this.value.map(selector));
    }
    filterCollection(selector) {
        return new ReactiveCollection(this.value.filter(selector));
    }
    forEach(action) {
        this.value.forEach(action);
        return this;
    }
    subscribe(observer) {
        return this.array.subscribe(observer);
    }
    filter(selector) {
        return this.array.filter(selector);
    }
    map(selector) {
        return this.array.map(selector);
    }
    debounceWithTimeout(dueTime, scheduler) {
        return this.array.throttleTime(dueTime, scheduler);
    }
    debounceWithSelector(selector) {
        return this.array.throttle(selector);
    }
    bufferTime(timeSpan, scheduler) {
        return this.array.bufferTime(timeSpan, scheduler);
    }
    bufferCount(count, skip) {
        return this.array.bufferCount(count, skip);
    }
    bufferTimeCount(timeSpan, count, skip, scheduler) {
        return this.array.bufferTimeCount(timeSpan, count, skip, scheduler);
    }
    zip(other) {
        return this.array.zip(other);
    }
    asObservable() {
        return this.array.asObservable();
    }
    asObserver() {
        return this.array.asObserver();
    }
    asSubject() {
        return this.array.asSubject();
    }
    asBehaviourSubject() {
        return this.array.asBehaviourSubject();
    }
}
exports.ReactiveCollection = ReactiveCollection;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicmVhY3RpdmUtY29sbGVjdGlvbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9yZWFjdGl2ZS1jb2xsZWN0aW9uLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsK0JBUWM7QUFHZCxtQ0FBMkM7QUFFM0MsNEJBQTRCO0FBRTVCO0lBb0JFLFlBQVksUUFBYSxFQUFFO1FBbkJuQixXQUFNLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQUNuRCxXQUFNLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQUNuRCxZQUFPLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQUNwRCxjQUFTLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQUN0RCxZQUFPLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQUNwRCxZQUFPLEdBQXFCLElBQUksb0JBQWEsQ0FBSSxDQUFDLENBQUMsQ0FBQztRQWUxRCxJQUFJLENBQUMsS0FBSyxHQUFHLElBQUksd0JBQWdCLENBQU0sS0FBSyxDQUFDLENBQUM7UUFFOUMsSUFBSSxDQUFDLElBQUksR0FBRztZQUNWLElBQUksQ0FBQyxlQUFlLENBQUMsTUFBTTtnQkFDekIsTUFBTSxDQUFDLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQztnQkFDckIsQ0FBQyxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQztnQkFDZixJQUFJLENBQUMsS0FBSyxHQUFHLENBQUMsQ0FBQztZQUNqQixDQUFDLENBQUM7WUFDRixJQUFJLENBQUMsa0JBQWtCLENBQUMsU0FBUztnQkFDL0IsTUFBTSxDQUFDLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQztnQkFDckIsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsQ0FBQztnQkFDckIsSUFBSSxDQUFDLEtBQUssR0FBRyxDQUFDLENBQUM7WUFDakIsQ0FBQyxDQUFDO1NBQ0gsQ0FBQztJQUNKLENBQUM7SUF2QkQsSUFBVyxLQUFLO1FBQ2QsTUFBTSxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsS0FBSyxDQUFDO0lBQzFCLENBQUM7SUFFRCxJQUFXLEtBQUssQ0FBQyxLQUFVO1FBQ3pCLElBQUksQ0FBQyxLQUFLLENBQUMsS0FBSyxHQUFHLEtBQUssQ0FBQztJQUMzQixDQUFDO0lBbUJNLE9BQU87UUFDWixJQUFJLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxHQUFHLElBQUksR0FBRyxDQUFDLFdBQVcsRUFBRSxDQUFDLENBQUM7SUFDOUMsQ0FBQztJQUVNLGVBQWUsQ0FDcEIsUUFBMEM7UUFFMUMsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNO2FBQ2YsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLGNBQWMsQ0FDbkIsUUFBMEM7UUFFMUMsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNO2FBQ2YsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLGdCQUFnQixDQUNyQixRQUEwQztRQUUxQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU87YUFDaEIsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLGtCQUFrQixDQUN2QixRQUEwQztRQUUxQyxNQUFNLENBQUMsSUFBSSxDQUFDLFNBQVM7YUFDbEIsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLGlCQUFpQixDQUN0QixRQUEwQztRQUUxQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU87YUFDaEIsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLGlCQUFpQixDQUN0QixRQUEwQztRQUUxQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU87YUFDaEIsU0FBUyxDQUFDLGdCQUFTLENBQUMsSUFBSSxDQUFDO2FBQ3pCLFdBQVcsQ0FBQyxnQkFBUyxDQUFDLElBQUksQ0FBQzthQUMzQixTQUFTLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDekIsQ0FBQztJQUVNLElBQUksQ0FBQyxLQUFRO1FBQ2xCLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxDQUFDO1FBQ3hCLE1BQU0sQ0FBQyxJQUFJLENBQUM7SUFDZCxDQUFDO0lBRU0sR0FBRyxDQUFDLEtBQVE7UUFDakIsTUFBTSxDQUFDLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQztRQUNyQixNQUFNLE1BQU0sR0FBRyxDQUFDLENBQUMsR0FBRyxFQUFFLENBQUM7UUFDdkIsSUFBSSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUM7UUFDekIsSUFBSSxDQUFDLEtBQUssR0FBRyxDQUFDLENBQUM7UUFDZixNQUFNLENBQUMsTUFBTSxDQUFDO0lBQ2hCLENBQUM7SUFFTSxLQUFLO1FBQ1YsTUFBTSxDQUFDLEdBQUcsSUFBSSxDQUFDLEtBQUssQ0FBQztRQUNyQixNQUFNLE9BQU8sR0FBRyxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUM7UUFDMUIsSUFBSSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7UUFDM0IsSUFBSSxDQUFDLEtBQUssR0FBRyxDQUFDLENBQUM7UUFDZixNQUFNLENBQUMsT0FBTyxDQUFDO0lBQ2pCLENBQUM7SUFFTSxPQUFPLENBQUMsS0FBUTtRQUNyQixJQUFJLENBQUMsU0FBUyxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUMzQixNQUFNLENBQUMsSUFBSSxDQUFDO0lBQ2QsQ0FBQztJQUVNLE1BQU0sQ0FBQyxLQUFRO1FBQ3BCLE1BQU0sQ0FBQyxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUM7UUFDckIsTUFBTSxPQUFPLEdBQUcsQ0FBQyxDQUFDLE1BQU0sQ0FBQyxDQUFDLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUM7UUFDM0MsSUFBSSxDQUFDLEtBQUssR0FBRyxDQUFDLENBQUM7UUFDZixJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQztRQUM5QixNQUFNLENBQUMsSUFBSSxDQUFDO0lBQ2QsQ0FBQztJQVVNLE1BQU07UUFDWCxNQUFNLEtBQUssR0FBRyxJQUFJLENBQUMsS0FBSyxDQUFDO1FBQ3pCLE1BQU0sT0FBTyxHQUFHLEtBQUssQ0FBQyxLQUFLLEVBQUUsQ0FBQztRQUM5QixLQUFLLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQ3BCLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQzNCLElBQUksQ0FBQyxLQUFLLEdBQUcsS0FBSyxDQUFDO1FBQ25CLE1BQU0sQ0FBQyxPQUFPLENBQUM7SUFDakIsQ0FBQztJQUVNLFVBQVUsQ0FBQyxNQUEwQjtRQUMxQyxDQUFDLENBQUMsS0FBSyxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsTUFBTSxDQUFDLENBQUMsT0FBTyxDQUFDLENBQUM7WUFDbEMsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLEVBQUUsQ0FBQyxDQUFDO1FBQ3hCLENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQztJQUVNLGFBQWEsQ0FBSSxRQUF5QjtRQUMvQyxNQUFNLENBQUMsSUFBSSxrQkFBa0IsQ0FBSSxJQUFJLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO0lBQzdELENBQUM7SUFFTSxnQkFBZ0IsQ0FDckIsUUFBK0I7UUFFL0IsTUFBTSxDQUFDLElBQUksa0JBQWtCLENBQUksSUFBSSxDQUFDLEtBQUssQ0FBQyxNQUFNLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztJQUNoRSxDQUFDO0lBRU0sT0FBTyxDQUFDLE1BQTBCO1FBQ3ZDLElBQUksQ0FBQyxLQUFLLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFDO1FBQzNCLE1BQU0sQ0FBQyxJQUFJLENBQUM7SUFDZCxDQUFDO0lBRU0sU0FBUyxDQUNkLFFBQThDO1FBRTlDLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLFNBQVMsQ0FBQyxRQUFRLENBQUMsQ0FBQztJQUN4QyxDQUFDO0lBRU0sTUFBTSxDQUFDLFFBQWlDO1FBQzdDLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLE1BQU0sQ0FBQyxRQUFRLENBQUMsQ0FBQztJQUNyQyxDQUFDO0lBRU0sR0FBRyxDQUFJLFFBQTJCO1FBQ3ZDLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxRQUFRLENBQUMsQ0FBQztJQUNsQyxDQUFDO0lBRU0sbUJBQW1CLENBQUMsT0FBZSxFQUFFLFNBQXNCO1FBQ2hFLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLFlBQVksQ0FBQyxPQUFPLEVBQUUsU0FBUyxDQUFDLENBQUM7SUFDckQsQ0FBQztJQUVNLG9CQUFvQixDQUN6QixRQUE4QztRQUU5QyxNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxRQUFRLENBQUMsUUFBUSxDQUFDLENBQUM7SUFDdkMsQ0FBQztJQUVNLFVBQVUsQ0FDZixRQUFnQixFQUNoQixTQUFzQjtRQUV0QixNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxVQUFVLENBQUMsUUFBUSxFQUFFLFNBQVMsQ0FBQyxDQUFDO0lBQ3BELENBQUM7SUFFTSxXQUFXLENBQUMsS0FBYSxFQUFFLElBQWE7UUFDN0MsTUFBTSxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsV0FBVyxDQUFDLEtBQUssRUFBRSxJQUFJLENBQUMsQ0FBQztJQUM3QyxDQUFDO0lBRU0sZUFBZSxDQUNwQixRQUFnQixFQUNoQixLQUFhLEVBQ2IsSUFBYSxFQUNiLFNBQXNCO1FBRXRCLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLGVBQWUsQ0FBQyxRQUFRLEVBQUUsS0FBSyxFQUFFLElBQUksRUFBRSxTQUFTLENBQUMsQ0FBQztJQUN0RSxDQUFDO0lBRU0sR0FBRyxDQUFJLEtBQW9CO1FBQ2hDLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLEdBQUcsQ0FBQyxLQUFLLENBQUMsQ0FBQztJQUMvQixDQUFDO0lBRU0sWUFBWTtRQUNqQixNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxZQUFZLEVBQUUsQ0FBQztJQUNuQyxDQUFDO0lBRU0sVUFBVTtRQUNmLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLFVBQVUsRUFBRSxDQUFDO0lBQ2pDLENBQUM7SUFFTSxTQUFTO1FBQ2QsTUFBTSxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsU0FBUyxFQUFFLENBQUM7SUFDaEMsQ0FBQztJQUVNLGtCQUFrQjtRQUN2QixNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxrQkFBa0IsRUFBRSxDQUFDO0lBQ3pDLENBQUM7Q0FDRjtBQXRPRCxnREFzT0MifQ==