I need to obtain data from websocket and I want to use RxJS to do so. 

There is a **websocket 1** for the latest initial data (~1000 records) and **websocket 2** for the incremental updates.

I have created two observables: 

* `initalState$` that goes to **websocket 1** and fetches the initial data and then completes.
* `updateEvent$` that goes to **websocket 2** and continuously receives updates.

My initial implementation was: 

```js
initialState.subscribe(initialData=> {
    console.log(initialData);
    updateEvent.subscribe(updateEvent => {
        console.log(updateEvent);
    });
});

```

The issue that I'm facing is that there is a gap after fetching the **initalState** and receiving the first update (**updateEvent**).

(I might lose update that happens after I fetch the initial data and before the subscribe).

Is there some practical way that I can create a new Observer that subscribes to both of my observers at the same time and buffer the **updateEvent** observer until the **initalState** completes and then have them in the right order "initial data first" then "updates" ? 

Basically making the initialState just the "first" update, but making sure there aren't any missing updates after that.