| import { scheduleObservable } from './scheduleObservable'; |
| import { schedulePromise } from './schedulePromise'; |
| import { scheduleArray } from './scheduleArray'; |
| import { scheduleIterable } from './scheduleIterable'; |
| import { isInteropObservable } from '../util/isInteropObservable'; |
| import { isPromise } from '../util/isPromise'; |
| import { isArrayLike } from '../util/isArrayLike'; |
| import { isIterable } from '../util/isIterable'; |
| export function scheduled(input, scheduler) { |
| if (input != null) { |
| if (isInteropObservable(input)) { |
| return scheduleObservable(input, scheduler); |
| } |
| else if (isPromise(input)) { |
| return schedulePromise(input, scheduler); |
| } |
| else if (isArrayLike(input)) { |
| return scheduleArray(input, scheduler); |
| } |
| else if (isIterable(input) || typeof input === 'string') { |
| return scheduleIterable(input, scheduler); |
| } |
| } |
| throw new TypeError((input !== null && typeof input || input) + ' is not observable'); |
| } |
| //# sourceMappingURL=scheduled.js.map |
