angular2 http请求和websocket

<分区>

大家好，我有一个应用程序，直到现在只执行 http 请求来检索数据...现在的问题是我们还有一个 websocket，但我不知道如何将它们结合起来:

这是我的 http 请求:

 public stock(): Observable<any> {
    if (!this._stock) {
        // rest api
        this._stock = this.http.get(url)
            .map((stock: Response) => {
                // cache the value
                stock.json().items.forEach((item) => {
                    this._stock[item.productKey] = item;
                });
                return this._stock;
            })
            .publishReplay(1)
            .refCount();
    }
    return this._stock;
}

这是网络套接字:

public getStockMessages(): Observable<any> {
    return new Observable(obs => this.inventoryChannel.on(`STOCK`, (data) => {
        return obs.next(data);
    }));
}

最佳答案

鉴于您上面所说的，您似乎希望: