Reactive-Extensions / RxJS

The Reactive Extensions for JavaScript
http://reactivex.io
Other
19.49k stars 2.1k forks source link

fetch data from a database using observables #1539

Closed slim-hmidi closed 6 years ago

slim-hmidi commented 6 years ago

I'm trying to get data from a database using two observables:

const roomData$ = Observable.create((observer) => {
   estab
     .query()
     .where('estab.type', 'like', 'rooms')
     .then((rooms) => {
       observer.next(rooms);
       observer.complete();
     })
     .catch((error) => {
       observer.error(error);
     });
 })

const hotelData$ = Observable.create((observer) => {
   estab
     .query()
     .where('estab.type', 'like', 'hotels')
     .then((rooms) => {
       observer.next(rooms);
       observer.complete();
     })
     .catch((error) => {
       observer.error(error);
     });
 })
hotelContentData$ = Observable.merge(roomData$, hotelData$)

Is it possible for many observables to read from a database simulatenously? Because I got only a data from one of them not both.

slim-hmidi commented 6 years ago

I solved my problem with combineLatest():

hotelContentData$ = Observable.combineLatest(roomData$, hotelData$)