1import { Observable } from '../Observable'; 2import { SchedulerLike } from '../types'; 3import { subscribeToArray } from '../util/subscribeToArray'; 4import { scheduleArray } from '../scheduled/scheduleArray'; 5 6export function fromArray<T>(input: ArrayLike<T>, scheduler?: SchedulerLike) { 7 if (!scheduler) { 8 return new Observable<T>(subscribeToArray(input)); 9 } else { 10 return scheduleArray(input, scheduler); 11 } 12} 13