fromArray.ts 423 B

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