.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/fromIterable.ts

   1 import { Observable } from '../Observable';
   2 import { SchedulerLike } from '../types';
   3 import { subscribeToIterable } from '../util/subscribeToIterable';
   4 import { scheduleIterable } from '../scheduled/scheduleIterable';
   5
   6 export function fromIterable<T>(input: Iterable<T>, scheduler?: SchedulerLike) {
   7   if (!input) {
   8     throw new Error('Iterable cannot be null');
   9   }
  10   if (!scheduler) {
  11     return new Observable<T>(subscribeToIterable(input));
  12   } else {
  13     return scheduleIterable(input, scheduler);
  14   }
  15 }