Rxjs Wiederholen mit Delay-Funktion

Ich versuche, mit retry mit delay Funktion erwarte ich von der Funktion Anruf nach 1000ms Verzögerung, aber es doesnot, was kann der Fehler hier?
Blick auf die Ausgabe in der Konsole, es ist der gleiche time 16:22:48.

Erwarte ich 16:22:48, 16:22:59 ...

canCreate: boolean;
getSomeFunction(): Observable<boolean> {
        return new Observable<boolean>(
            observer => {
                const canCreate = null; //this is just null for now, will some value later
                if (canCreate == null) {
                    observer.error('error');
                } else {
                    observer.next(true);
                }
                observer.complete();
            }
        )
    }


this.getSomeFunction()
      .do((value) => {
        this.cCreate = value;
      }, (error) => {
         console.log(error + new Date().toTimeString());
      })
      .delay(1000)
      .retry(10)
      .subscribe(
        value => this.cCreate = value,
        error => {
          this.cCreate = false;
        },
        () => {}
      );
  }

- und Konsolen-Ergebnis :

Rxjs Wiederholen mit Delay-Funktion

InformationsquelleAutor Mujah Maskey | 2017-07-07
Schreibe einen Kommentar