| "use strict"; |
| Object.defineProperty(exports, "__esModule", { value: true }); |
| exports.scheduled = void 0; |
| var scheduleObservable_1 = require("./scheduleObservable"); |
| var schedulePromise_1 = require("./schedulePromise"); |
| var scheduleArray_1 = require("./scheduleArray"); |
| var scheduleIterable_1 = require("./scheduleIterable"); |
| var scheduleAsyncIterable_1 = require("./scheduleAsyncIterable"); |
| var isInteropObservable_1 = require("../util/isInteropObservable"); |
| var isPromise_1 = require("../util/isPromise"); |
| var isArrayLike_1 = require("../util/isArrayLike"); |
| var isIterable_1 = require("../util/isIterable"); |
| var isAsyncIterable_1 = require("../util/isAsyncIterable"); |
| var throwUnobservableError_1 = require("../util/throwUnobservableError"); |
| var isReadableStreamLike_1 = require("../util/isReadableStreamLike"); |
| var scheduleReadableStreamLike_1 = require("./scheduleReadableStreamLike"); |
| function scheduled(input, scheduler) { |
| if (input != null) { |
| if (isInteropObservable_1.isInteropObservable(input)) { |
| return scheduleObservable_1.scheduleObservable(input, scheduler); |
| } |
| if (isArrayLike_1.isArrayLike(input)) { |
| return scheduleArray_1.scheduleArray(input, scheduler); |
| } |
| if (isPromise_1.isPromise(input)) { |
| return schedulePromise_1.schedulePromise(input, scheduler); |
| } |
| if (isAsyncIterable_1.isAsyncIterable(input)) { |
| return scheduleAsyncIterable_1.scheduleAsyncIterable(input, scheduler); |
| } |
| if (isIterable_1.isIterable(input)) { |
| return scheduleIterable_1.scheduleIterable(input, scheduler); |
| } |
| if (isReadableStreamLike_1.isReadableStreamLike(input)) { |
| return scheduleReadableStreamLike_1.scheduleReadableStreamLike(input, scheduler); |
| } |
| } |
| throw throwUnobservableError_1.createInvalidObservableTypeError(input); |
| } |
| exports.scheduled = scheduled; |
| //# sourceMappingURL=scheduled.js.map |
