角2更新可观测到的

Question

为了创建一个可以观察到的方法，每5秒运行一次API调用并检查新的用户活动，我使用了以下方法：

getLastActivity()
{
    return Observable.interval(5000).startWith(0)
        .switchMap(() => this.http.get('user-activity'))
        .map(res => res.json());
}

我在显示活动的组件中订阅它，这是我的侧栏(所有页面)。

let activitySub = this._myService.getLastActivity()
        .subscribe( data => this.activities = data.user_activities);

有时，用户正在进行一个活动，我希望在sidenav中显示新添加的活动，而不是等待1-5秒(可观察的时间)。

使用对象push手动向activity数组添加操作不是一个选项，因为这些操作是插入服务器端的。

当我试图逃跑时：

this.getLastActivity.subscribe(() =>{});

我犯了一个错误，因为我已经订阅了这个可观察到的。

我的问题是：如何执行可观察的API调用，即使可观察的下一次运行所剩的时间还没有过去？

Answer 1

您需要合并两个可观察的：“间隔”可观测和“用户活动”可观测。

let intervalOb = Observable.interval(5000).startWith(0);
let useractivityOb = ... // you need to convert user activity to an observable
Observable.merge(intervalOb, useractivityOb)
    .switchMap(() => this.http.get('user-activity'))
    .map(res => res.json());

或者你可以用一个主题：

let subject = new Subject();
subject.switchMap(() => this.http.get('user-activity'))
    .map(res => res.json());
Observable.interval(5000).startWith(0).subscribe(subject);
// and now everytime there is a user activity, call subject.next()