JSFiddle - React, Tailwind, and code Playground

HTML

<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

TypeScript

class MyClass {
  prop: number;
  static fromObject(src: Object) {
  	var obj = new MyClass();
    obj.prop = src.prop;
    return obj;
  }
}

Rx.Observable.of('[{"prop":1},{"prop":2},{"prop":3}]')
  .map(val => JSON.parse(val))
  .exhaustMap(val => new Rx.Observable.from(val))
  .map(val => MyClass.fromObject(val))
  .subscribe(
    item => console.log('Next: ', item),
    error => console.log('Error:', error),
    _ => console.log('Completed')
	);