RxJS catch ** ve ** Gözlemlenebilir bir yeniden deneyin

Question

Kullanım durumum, bir Gözden geçirme işleminin başarı ve başarısızlık eylemlerini eşleştirmektir. Bir ağ çağrısı yapıyorum (söz veren bir işlevle), başarılı olursa bir hata eyleminden başarısız olursa bir başarı eylemini iletmem gerekiyor. Gözlemlenebilir kendisi devam etmelidir. RxJS'nin arama yapabildiğim her şey için, hatayı yakalamak ve orijinali yeniden denemek için bir mekanizma yoktur.

error$ = new Rx.Subject(); 

searchResultAction$ = search$ 
    .flatMap(getSearchResultsPromise) 
    .map((resuls) => { 
     return { 
      type: 'SUCCESS_ACTION', 
      payload: { 
       results 
      } 
     } 
    }) 
    .retryWhen((err$) => { 
     return err$ 
      .pluck('query') 
      .do(error$.onNext.bind(error$)); 
    }); 

searchErrorAction$ 
    .map((query) => { 
     return { 
      type: 'ERROR_ACTION', 
      payload: { 
       query, 
       message: 'Error while retrieving data' 
      } 
     } 
    }); 

action$ = Observable 
    .merge(
     searchResultAction$, 
     searchErrorAction$ 
    ) 
    .doOnError(err => console.error('Ignored error: ', err)) 
    .retry(); 

action$.subscribe(dispatch); 

yani ben bir konu oluşturmak ve bu konuda içine hataları itmek ve bu hata eylemlerin gözlemlenebilir oluşturmak: Ben memnun değilim benim kod çözümü şu var.

RxJS'de bunu yapmanın daha iyi bir alternatifi var mı? Temel olarak, hangi hatanın meydana geldiğine dair bir bildirim yaymak istiyorum ve sonra Gözlemlenebilir zaten ne yapıyorsa devam edin.

Answer 1

Bu yeniden denemek istiyorum başarısız sorgular:

var action$ = search$ 
    .flatMap(value => { 
     // create an observable that will execute 
     // the query each time it is subscribed 
     const query = Rx.Observable.defer(() => getSearchResultsPromise(value)); 

     // add a catch clause to "ignore" the error 
     return query.catch(err => { 
      console.log("ignoring error: ", err); 
      return Observable.empty(); // no result for this query 
     })); 
    }) 
    .map(payload => ({ type: "SUCCESS_ACTION", payload })); 

action$.subscribe(dispatcher);