Function next

src/Observable.js:144–168

(value)

    },

    next(value) {

        let subscription = this._subscription;

        // If the stream if closed, then return undefined
        if (subscriptionClosed(subscription))
            return undefined;

        let observer = subscription._observer;

        try {
            let m = getMethod(observer, "next");

            // If the observer doesn't support "next", then return undefined
            if (!m)
                return undefined;

            // Send the next value to the sink
            m.call(observer, value);
        }
        catch(e) {
            // HostReportErrors(e);
        }
        return undefined;
    },

    error(value) {