a59a863108e0d7becdcd3e9a069934cb5d6a35365ffe347642028e34f71781177710fd9c6265c78e6016085866a2b366e85a50e221855e3f8126e985905472 511 B

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