Повторяющиеся наблюдаемые потоки

Question

У меня есть поток наблюдаемых событий, которые заканчиваются на событии. Однако, как только я закончил, мне нужно, чтобы поток начинался снова с самого начала. Представление потока ниже:

awaitStartEvent() 
    .switchMap(value -> awaitSecondEvent(value)) 
    .subscribe(result -> { 
    doSomethingWithResult(result); 
    // need to start at awaitStartEvent again here 
    }, error -> { 
    handleError(error); 
    // need to start at awaitStartEvent again here 
    } 

Что такое хороший способ справиться с этой ситуацией?

Answer 1

Как следует из комментария @ maxost, используйте оператор Repeat. Если вы хотите, чтобы он продолжался и перед лицом ошибок, вам также нужно добавить оператора Retry. Здесь вам нужно будет поместить свою логику handleError, поскольку окончательная подписка никогда не увидит эти ошибки.

Answer 2

Вам нужно repeat и retry, но так как у вас есть handleError побочный эффект в вопросе, исключение не будет распространяться вниз по течению, чтобы справиться с оператором retry.

Здесь используется класс операторов do.

awaitStartEvent() 
    .switchMap(value -> awaitSecondEvent(value)) 
    .doOnNext(result -> { doSomethingWithResult(result); }) 
    .doOnError(error -> { handleError(error); }) 
    .repeat() 
    .retry() 
    .subscribe(); 

Answer 3

awaitStartEvent() 
    .switchMap(value -> awaitSecondEvent(value)) 
    .doOnNext(result -> doSomethingWithResult(result)) //handle result 
    .repeat() //resubsribe when onComplete called 
    .doOnError(error -> handleError(error)) //handle error 
    .retry() //resubscribe when onError called 
    .subscribe();