问观测角2环

EN

let src: Observable<any>;// the source Observable
src.map(data => {
  if (!validate(data)) {
     throw "Invalid data";
  }
  return data;
})
.retry() // you can limit the number of retries
.subscribe(data => {
   // Do something with the data
});

let src: Observable<any>;// the source Observable
src.map(data => {
  if (!validate(data)) {
     throw "Invalid data";
  }
  return data;
})
.retryWhen(errors => errors.map(err => {
   if (err != "Invalid data") {
    throw err;
   }
 })
.subscribe(data => {
   // Do something with the data
});

public getData(): Observable<any> {}

public refresh() {
   this.yourService.getData().subscribe(data => {
      // validate data !
      if (dataValid(data) {
         // do something cool here .. !
      }
      else {
         this.refresh(); // do it again ..
      }
   });
}