관찰 가능 항목을 방출하기 전에 코드를 실행할 수있는 방법이 있습니까? (재 시도 목적으로)

Question

관찰 대상을 구독으로 다시 시도하고 싶습니다. 모든 것이 잘되었지만 지금은이 관찰을 다시 시도 할 때마다 몇 가지 코드를 실행하려고합니다. 어떤 제안?

observableItem.retry(1).subscribeWith(subscriber); 

Answer 1

대신 retry의 retryWhen 사용할 수 있습니다.

observableItem 
    .retryWhen(attempts -> { 
    return attemps.flatMap(error -> { 
     // TODO: Do what you want here... 

     // If you return an Observable with an `onNext` event => retry 
     // else if you return an Observable with an error => no retry 
     return Observable.just(new Object()); 
    }) 
    }) 
    .subscribeWith(subscriber); 

Answer 2

당신은 가입 할 때 관찰 (관찰이 항목을 방출하기 전에) 작동 doOnSubscribe 연산자가 필요합니다.

... 
observableItem 
     .doOnSubscribe(subscriber1 -> { 
      // Do whatever you want to de before retry. 
     }) 
     .retry(1) 
     .subscribeWith(subscriber) 
... 

참고 : 테스트하지 않았습니다. 그것을 시험하고 알려주세요.

희망이 있습니다.