docs/vendor.js
function fromObservable(input, scheduler) {
    if (!scheduler) {
        return new _Observable__WEBPACK_IMPORTED_MODULE_0__["Observable"](Object(_util_subscribeToObservable__WEBPACK_IMPORTED_MODULE_3__["subscribeToObservable"])(input));
    }
    else {
        return new _Observable__WEBPACK_IMPORTED_MODULE_0__["Observable"](function (subscriber) {
            var sub = new _Subscription__WEBPACK_IMPORTED_MODULE_1__["Subscription"]();
            sub.add(scheduler.schedule(function () {
                var observable = input[_symbol_observable__WEBPACK_IMPORTED_MODULE_2__["observable"]]();
                sub.add(observable.subscribe({
                    next: function (value) { sub.add(scheduler.schedule(function () { return subscriber.next(value); })); },
                    error: function (err) { sub.add(scheduler.schedule(function () { return subscriber.error(err); })); },
                    complete: function () { sub.add(scheduler.schedule(function () { return subscriber.complete(); })); },
                }));
            }));
            return sub;
        });
    }
}
function fromObservable(input, scheduler) {
    if (!scheduler) {
        return new _Observable__WEBPACK_IMPORTED_MODULE_0__["Observable"](Object(_util_subscribeToObservable__WEBPACK_IMPORTED_MODULE_3__["subscribeToObservable"])(input));
    }
    else {
        return new _Observable__WEBPACK_IMPORTED_MODULE_0__["Observable"](function (subscriber) {
            var sub = new _Subscription__WEBPACK_IMPORTED_MODULE_1__["Subscription"]();
            sub.add(scheduler.schedule(function () {
                var observable = input[_symbol_observable__WEBPACK_IMPORTED_MODULE_2__["observable"]]();
                sub.add(observable.subscribe({
                    next: function (value) { sub.add(scheduler.schedule(function () { return subscriber.next(value); })); },
                    error: function (err) { sub.add(scheduler.schedule(function () { return subscriber.error(err); })); },
                    complete: function () { sub.add(scheduler.schedule(function () { return subscriber.complete(); })); },
                }));
            }));
            return sub;
        });
    }
}
function fromObservable ( input , scheduler ) { if ( ! scheduler ) { return new _Observable__WEBPACK_IMPORTED_MODULE_0__ [ "Observable" ] ( Object ( _util_subscribeToObservable__WEBPACK_IMPORTED_MODULE_3__ [ "subscribeToObservable" ] ) ( input ) ) ; } else { return new _Observable__WEBPACK_IMPORTED_MODULE_0__ [ "Observable" ] ( function ( subscriber ) { var sub = new _Subscription__WEBPACK_IMPORTED_MODULE_1__ [ "Subscription" ] ( ) ; sub . add ( scheduler . schedule ( function ( ) { var observable = input [ _symbol_observable__WEBPACK_IMPORTED_MODULE_2__ [ "observable" ] ] ( ) ; sub . add ( observable . subscribe ( { next : function ( value ) { sub . add ( scheduler . schedule ( function ( ) { return subscriber . next ( value ) ; } ) ) ; } , error : function ( err ) { sub . add ( scheduler . schedule ( function ( ) { return subscriber . error ( err ) ; } ) ) ; } , complete : function ( ) { sub . add ( scheduler . schedule ( function ( ) { return subscriber . complete ( ) ; } ) ) ; } , } ) ) ; } ) ) ; return sub ; } ) ; } }
PURE_IMPORTS_START _Observable,_Subscription,_symbol_observable,_util_subscribeToObservable PURE_IMPORTS_END
PURE_IMPORTS_START _Observable _Subscription _symbol_observable _util_subscribeToObservable PURE_IMPORTS_END