ad664c26171152004a501a0a1d098a6aa330a04987720c69185b6c845fa67f35ebc8ae7c219df71f612bb6e49a61bc422dec9a982e96632f4ff1927d1bfd01 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. }