javascript - Cancel an Rx Observable interval call - Stack Overflow

admin管理员组

文章数量:1353655

I'm new to Angular 2 so maybe this is trivial - I'm trying to figure out how to cancel an Rx.Observable interval call that happens every 2 seconds. I subscribe to the Rx.Observable with this:

getTrainingStatusUpdates() {
    this.trainingService.getLatestTrainingStatus('train/status')
        .subscribe(res => {
            this.trainingStatus = res;
            if (this.trainingStatus == "COMPLETED") {
                //Training is plete
                //Stop getting updates
            }
        });
}

This is how my Rx.Observable interval call is handled in my service.ts file (this is called by the function above from a different file):

getLatestTrainingStatus(url: string) {
    return Rx.Observable
        .interval(2000)
        .flatMap(() => this._http.get(url))
        .map(<Response>(response) => {
            return response.text()
        });
}

As you can see in the subscription method, I simply want to stop the interval calls (every 2 seconds) when 'trainingStatus' is 'COMPLETED'.

I'm new to Angular 2 so maybe this is trivial - I'm trying to figure out how to cancel an Rx.Observable interval call that happens every 2 seconds. I subscribe to the Rx.Observable with this:

getTrainingStatusUpdates() {
    this.trainingService.getLatestTrainingStatus('train/status')
        .subscribe(res => {
            this.trainingStatus = res;
            if (this.trainingStatus == "COMPLETED") {
                //Training is plete
                //Stop getting updates
            }
        });
}

This is how my Rx.Observable interval call is handled in my service.ts file (this is called by the function above from a different file):

getLatestTrainingStatus(url: string) {
    return Rx.Observable
        .interval(2000)
        .flatMap(() => this._http.get(url))
        .map(<Response>(response) => {
            return response.text()
        });
}

As you can see in the subscription method, I simply want to stop the interval calls (every 2 seconds) when 'trainingStatus' is 'COMPLETED'.

• javascript
• angularjs
• typescript
• angular

Share Improve this question Follow asked Jul 12, 2016 at 16:13 Roka545Roka545 3,6362323 gold badges7070 silver badges111111 bronze badges

Add a ment  | 

2 Answers 2

Sorted by: Reset to default 6

That's possible with the unsubscribe option.

Every .subscribe() returns a subscription object. This object allows you to unsubscribe to the underlying Observable.

getTrainingStatusUpdates() {
    // here we are assigning the subsribe to a local variable
    let subscription = this.trainingService.getLatestTrainingStatus('train/status')
        .subscribe(res => {
            this.trainingStatus = res;
            if (this.trainingStatus == "COMPLETED") {
                //this will cancel the subscription to the observable
                subscription.unsubscribe()
            }
        });
}

getTrainingStatusUpdates() {
  this.trainingService.getLatestTrainingStatus('train/status')
  .do(res => this.trainingStatus = res)
  .first(res => res == "COMPLETED")
  .subscribe(/* Do stuff, if any */);
}

You don't have to unsubscribe / stop the interval. It will be stopped when res == "COMPLETED"

本文标签： javascriptCancel an Rx Observable interval callStack Overflow