使用RxJS刷新/重新加载热可观测序列

Question

我正在Angular 2中的Portal上工作。登录时，我向服务器请求获取登录的用户配置文件。当应用程序加载时，获取用户配置文件的方法返回在6个不同位置订阅的可观察对象。

如果我使用冷可观察，这将导致对服务器的6个API调用。因此，我通过添加.publishLast().refCount().切换到了热门观察

这导致单个请求共享数据，因为用户配置文件不会在后续请求中更新。

问题从这里开始：

现在我有一个编辑配置文件功能，它通过HTTP PUT更新用户配置文件，因此，我想使之前订阅的Observable过期，并以某种方式再次触发序列，以便再次执行API，订阅接收更新的数据。

有没有什么方法可以重新启动/重新触发已经订阅的可观察序列？

以下是获取用户可观察的代码

fetch(){
this.userObservable = Observable.fromPromise(this.getToken())
.switchMap(token => {
let headers = new Headers();
headers.append('Authorization', `Bearer ${token}`);
return this.http.get('/api/v1/admin/users/me?includes=role', {headers: headers})
})
.map((res: Response) => {
let retVal: any = {
data: new Deserializer({
keyForAttribute: 'camelCase'
}).deserialize(res.json())
};
this.user = retVal.data as MpUser;
this.user.role = MpRoles[retVal.data.role[0].name];
return this.user;
})
.publishLast()
.refCount();
}

Answer 1

您可以尝试引入subject来触发提取：

private fetchTrigger = new BehaviorSubject(null);
triggerFetch() {
this.fetchTrigger.next();
}
fetch() {
this.userObservable = Observable
.combineLatest(
Observable.fromPromise(this.getToken()),
this.fetchTrigger
)
.switchMap(([token]) => {
...
})
...
.publishLast()
.refCount();
}

请注意，在此示例中，token仅被检索一次。如果您需要在每次刷新时获得新的令牌：

private fetchTrigger = new BehaviorSubject(null);
triggerFetch() {
this.fetchTrigger.next();
}
fetch() {
this.userObservable = this.fetchTrigger
.switchMap(() => Observable.fromPromise(this.getToken()))
.switchMap(token => {
...
})
...
.publishLast()
.refCount();
}