Server IP : 150.95.80.236 / Your IP : 3.145.179.177 Web Server : Apache System : Linux host-150-95-80-236 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : social-telecare ( 10000) PHP Version : 7.4.33 Disable Function : opcache_get_status MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/vhosts/pcu.in.th/api-uat.pcu.in.th/node_modules/rxjs/dist/esm5/internal/scheduled/ |
Upload File : |
import { scheduleObservable } from './scheduleObservable'; import { schedulePromise } from './schedulePromise'; import { scheduleArray } from './scheduleArray'; import { scheduleIterable } from './scheduleIterable'; import { scheduleAsyncIterable } from './scheduleAsyncIterable'; import { isInteropObservable } from '../util/isInteropObservable'; import { isPromise } from '../util/isPromise'; import { isArrayLike } from '../util/isArrayLike'; import { isIterable } from '../util/isIterable'; import { isAsyncIterable } from '../util/isAsyncIterable'; import { createInvalidObservableTypeError } from '../util/throwUnobservableError'; import { isReadableStreamLike } from '../util/isReadableStreamLike'; import { scheduleReadableStreamLike } from './scheduleReadableStreamLike'; export function scheduled(input, scheduler) { if (input != null) { if (isInteropObservable(input)) { return scheduleObservable(input, scheduler); } if (isArrayLike(input)) { return scheduleArray(input, scheduler); } if (isPromise(input)) { return schedulePromise(input, scheduler); } if (isAsyncIterable(input)) { return scheduleAsyncIterable(input, scheduler); } if (isIterable(input)) { return scheduleIterable(input, scheduler); } if (isReadableStreamLike(input)) { return scheduleReadableStreamLike(input, scheduler); } } throw createInvalidObservableTypeError(input); } //# sourceMappingURL=scheduled.js.map