如何用新的observable替换http observable？

Question

我想我根本不理解角2的rxjs可观测物的概念。

我创建了一个可观察属性，其他人可以订阅该属性并获取http调用结果的数据。

如果我想发出另一个http请求，可能需要修改一些参数以提取一些新数据，该怎么办？我是否要用这个新的可观察物替换可观察物？这是否破坏了我的订阅组件与前一个可观察组件的订阅？

Answer 1

免责声明：我没有使用angular2，但我确实经常使用RxJS。

我可以说，典型的情况是，对于像http请求这样的单发事件，生成的Observable只能从该请求中得到一个结果。如果要发出更多请求，则需要再次调用该方法。即

从文件中

$http.get('/people.json').map(res => res.json()).subscribe(people => this.people = people);

现在，如果您计划发出多个后续请求，那么通常您会使用其他事件（可能是用户事件或网络事件）触发呼叫，您甚至可以将其设置为每隔几秒钟定期运行一次。要不“断开链”，您需要使用一个flatMap（基本上是.map（）.merge（））变体将结果展平为一个链。

例如，如果您有一个任意事件（注意语法可能会有一些变化，因为有几个版本的RxJS）：

Rx.Observable.fromEvent($someButton, 'click')
             //Gather the parameters for the request
             .map(e => {id : 'abc123'})
             //Flatten each request into a single stream so the observer
             //never knows the difference 
             .flatMap(params => $http.get(`/people/${params.id}`), 
                      (params, res) => res.json())
             //Do your update here
             .subscribe(person => this.people[person.id] = person);