Rxjs ForkJoin

by jacobwsmith

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.4.0/Rx.min.js"></script>

JavaScript

console.clear();

// mimic service
const database1$ = Rx.Observable.of('hello from database1').delay(1000);
const database2$ = Rx.Observable.of('hello from database2').delay(2000);

Rx.Observable.forkJoin(
	database1$,
  database2$
).subscribe(
	x => console.log('onNext: %s', x),
  e => console.log('onError: %s', e),
  () => console.log('onCompleted')
)