问题描述
Angular 2 ：2.0.0-alpha.31 / Typescript 1.5
目前我将我的服务作为一个简单的Class ，然后我将这个Class注入另一个组件。
例：
export class PlayerService {
http: Http;
players = [];
constructor( @Inject(Http) http) {
this.http = http;
}
getAll(callback) {
this.http.get('/data/players.json')
.toRx()
.map((res) => res.json())
.subscribe((data) => {
this.players= data;
callback(data);
});
}
add(player) {
//call webservice to save user
this.players.push(player); //only if save has work
}
delete(player) {
//Not implemented yet
}
get(id) {
//Not implemented yet
}
}
我想，我这样做的方式不对..
-
我正在使用
http.get().toRx().subscribe()？ 我以为我看到有人将Observable直接从toRx() -
如果两个组件同时请求玩家（
getAll()），则将执行两个查询。 我必须管理旗帜还是有另一种方式？ - 我在这里工作回调。 如果我想“立即”（没有异步）数据我该怎么办？
-
components会自动通知玩家添加/删除吗？ 我是否必须使用某种事件来处理这个问题（任何一个例子？）？
所以我的问题是：
- 是否有一种在Angular2中管理服务的常用方法？
1楼
Alfonso Presa
4
2015-08-22 16:27:29
首先，服务很好，就像你做的那样，这是使用Angular2的方法：将一个Class注入到其他组件中。
也就是说，关于你提出的其他问题，我宁愿返回并将结果存储在promise中，而不是使用回调：
getAll() {
return players || players = new Promise(
(resolve) => this.http.get('people.json').observer({next: resolve})
);
}
注意 ：您应该可以使用Observable.toPromise（）但由于某种原因它在Angular2中不适用于我
这样进一步调用getAll（）不会触发更多响应。
对于同步问题，你不应该这样做。 现在你已经将它放在一个承诺中，只需调用getAll（）并在请求玩家时返回一个承诺。
get(id) {
return getAll().then((result) => {return Promise.resolve(result[id])});
}
关于处理玩家添加和删除的方式，这正是Observables在RxJS中的意图。 您需要提供和Observable流，以便在播放器列表更改时通知其观察者。 你可以使用 ：
constructor( @Inject(Http) http) {
this.http = http;
this.myEventEmitter = new EventEmitter();
}
getUpdateStream() {
myEventEmitter.toRx();
}
当您更改玩家列表时，只需执行myEventEmitter.next(players)