@neo-one/react/FromStream.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
const React = tslib_1.__importStar(require("react"));
const shallowEqual_1 = require("./shallowEqual");
const initialValue = Symbol.for('initialValue');
class FromStream extends React.Component {
    constructor(props) {
        super(props);
        this.mutableMounted = false;
        this.state = {
            value: initialValue,
        };
        this.subscribe();
        this.mutableMounted = true;
    }
    componentWillUnmount() {
        this.mutableMounted = false;
        this.unsubscribe();
    }
    componentDidUpdate(prevProps) {
        const props = this.props;
        if ((prevProps.props != undefined && props.props == undefined) ||
            (prevProps.props == undefined && props.props != undefined) ||
            (prevProps.props != undefined &&
                props.props != undefined &&
                (prevProps.props.length !== props.props.length ||
                    prevProps.props.some((propA, idx) => !shallowEqual_1.shallowEqual(propA, props.props[idx]))))) {
            this.subscribe();
        }
    }
    render() {
        const { value } = this.state;
        if (value === initialValue) {
            return null;
        }
        return this.props.children(value);
    }
    subscribe() {
        this.unsubscribe();
        let stateSet = false;
        this.mutableSubscription = this.props.createStream().subscribe({
            next: (value) => {
                stateSet = true;
                this._setValue(value);
            },
        });
        if (!stateSet) {
            this._setValue(initialValue);
        }
    }
    _setValue(value) {
        if (this.mutableMounted) {
            this.setState({ value });
        }
        else {
            this.state = { value };
        }
    }
    unsubscribe() {
        if (this.mutableSubscription !== undefined) {
            this.mutableSubscription.unsubscribe();
            this.mutableSubscription = undefined;
        }
    }
}
exports.FromStream = FromStream;

//# sourceMappingURL=FromStream.js.map