Wie man einen http-Aufruf alle 2 Minuten mit RXJS?

Habe ich einen service zu machen, dass ein Anruf auf mein rest-service alle 2 Minuten. Auf meinem service ich habe die folgende Funktion

  getNotifications(token: string) {
     const body = 'xxxxxxxxx=' + token;
     return this.http.post('/rest/ssss/ddddddd/notificationcount', body, this.options)
          .map((res) => res.json());
  }

Auf meine Komponente nenne ich auch mein service-Funktion zum Aufruf der API.

this.notificationService.getNotifications(this.token).subscribe((data) => {
  console.log(data);
});

Möchte ich diesen Aufruf alle 2 Minuten, was ist der beste Weg, dies zu tun?

Hat man sich bei repeatWhen?

InformationsquelleAutor Ennio | 2017-06-28

29

Da Sie bereits Observables einfach machen, es zu nutzen 🙂 Obersvable.interval() ist Ihr guter Freund hier:

In der Komponente, dies zu tun:
```
Observable
    .interval(2*60*1000)
    .timeInterval()
    .flatMap(() => this.notificationService.getNotifications(this.token))
    .subscribe(data => {
        console.log(data);
    });
```
Erklärung:
1. .interval() schafft eine beobachtbare, das strahlt eine Veranstaltung jeden 2
  Minuten.
2. .timeInterval() konvertieren Sie eine Observable, die strahlt Elemente in einen
  das strahlt Hinweise auf die verstrichene Zeit zwischen diesen
  - Emissionen.
3. .flatMap() dann schließt Ihr jeden - of-service-Aufruf,
  Transformation der Ergebnisse in eine beobachtbare und zurückgeben. Diese sorgen
  dass die Ihren service-Aufruf an das 0., 2., 4., 6.....minute aufgerufen wird
  synchron. (denke es gibt eine Menge von .then()), ich.e -, service-bei der 2. minute wird nur aufgerufen werden, nachdem sich der 0. minute den Anruf, und 4. nur nach der 2., und so weiter.
4. .subscribe() schließlich können Sie sich anmelden, um die Daten
Update:

Wenn Sie pipeable Operatoren (rxjs5 und oben), leiten Sie einfach die Betreiber anstelle der Verkettung zu Ihnen:
```
interval(2 * 60 * 1000)
    .pipe(
        flatMap(() => this.notificationService.getNotifications(this.token))
    )
    .subscribe(data => console.log(data))
```
- Ich hatte einen ähnlichen Fall mit der beschriebenen in dieser Frage. Was muss ich wissen, denn ich bin Neuling auf Eckig ist, ob diese Daten dargestellt werden können, die dynamisch zu Seite. Lassen Sie uns sagen, dass dieser Daten ist ein array von Objekten, und ich Durchlaufen mit Ihnen an einen Tisch, würde diese Tabelle aktualisiert werden, mit dem 'neuen' vom Dienst zurückgegebene Daten werden alle 2 Minuten?
- ja. es wird, so lange, wie Sie binden Sie die Daten richtig
- Sie können tun, dass durch die Verwendung des async-Rohr im Winkel 5
- ja, das ist ein anderer Ansatz. Somit sind diese Daten nicht braucht, um ein array von Objekten, sondern das beobachten selbst, so dass der obige code muss geändert werden.
- Dieses wartet das Intervall vor dem abfeuern ist es Erste nennen...
InformationsquelleAutor CozyAzure
0

Wenn Sie nicht wollen, um einen http-Aufruf und wollen einfach etwas tun, nach 2 Minuten, dann können Sie etwas tun, wie unten.
```
 Observable.interval(2*60*1000)
  .subscribe(() => {
    //do something.
    //or callSomeMethod();
  });
```
Gibt es eine weitere wichtige Sache, die Sie tun möchte, sollte Man dies zerstören beobachten, sobald Sie verlassen die aktuelle Seite, weil Sie nicht wollen, die extra Berechnung geht hinter der Szene, wenn diese nicht wirklich benötigt.

Gibt es mehrere Optionen, um den Newsletter abbestellen zu beobachten.
1. Speichern, sollten Sie den Verweis auf die beobachtbaren und Abmelden in onDestroy Methode.
```
this.observableRef = Observable.interval(60000)
.subscribe(() => {
  //do something
 });

//call this method in OnDestroy method of the page.
this.observableRef.unsubscribe();
```
2. ODER verwenden Sie ngx-nehmen-bis-zu zerstören
```
Observable.interval(60000)
.takeUntil(this.destroyed$)
.subscribe(() => {
  // do something
});
```
InformationsquelleAutor Atif Saddique

-1

import {Observable} from 'rxjs/Rx';

  Observable.interval(2 * 60 * 1000).subscribe(x => {
    callyourmethod();
  });

Update Nach Kommentar

this.interval = setInterval(() => {
        this.yourservicecallmethod();
    }, 2 * 60 * 1000);

Vermutlich will er eine beobachtbare strahlt eine neue HTTP-Antwort, die alle zwei Minuten.

InformationsquelleAutor Rahul Singh

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.

Update: