Function error

src/Observable.js:170–200

(value)

    },

    error(value) {

        let subscription = this._subscription;

        // If the stream is closed, throw the error to the caller
        if (subscriptionClosed(subscription)) {
            return undefined;
        }

        let observer = subscription._observer;
        subscription._observer = undefined;

        try {

            let m = getMethod(observer, "error");

            // If the sink does not support "complete", then return undefined
            if (m) {
                m.call(observer, value);
            }
            else {
                // HostReportErrors(e);
            }
        } catch (e) {
            // HostReportErrors(e);
        }

        cleanupSubscription(subscription);

        return undefined;
    },

    complete() {