RxJS Playground

A blank canvas to play / experiment with RxJS: https://github.com/Reactive-Extensions/RxJS

by jgoemat

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.7/rx.all.js"></script>

TypeScript

console.clear();

var pdfObjects = {
	a: 'Object A',
  b: 'Object B',
  c: 'Object C'
};

var observables = [];
for(let key in pdfObjects) {
  let pdf = pdfObjects[key];
  function createObservable(p) {
    console.log('createObservable:', p, pdf, key);
  	return Rx.Observable.create(observer => {
      console.log('createObservable.create:', p, pdf, key);
      observer.onNext({ p: p, pdf: pdf, key: key});
      observer.onCompleted();
    });
  }
  observables.push(createObservable(pdf));
}

Rx.Observable.forkJoin(observables).subscribe(
	(next) => { console.log('next:', next); },
  (err) => { console.log('err:', err) },
  (completed) => {
  	console.log('completed');
  }
);