Пропустить наблюдаемый при повторной попытке

Question

Я собираю наблюдаемые RX, используя оператор concat.Я также использую оператор повтора, чтобы повторить попытку в случае любой ошибки.Тем не менее, я хотел бы пропустить некоторые наблюдаемые из источника при повторной попытке.Возможно ли это?

Observable.concat (
    Observable-A,
    Observable-B,
    Observable-C
).retry(ERROR);

Так, например, если Observable-A завершается, но Observable-B выдает ошибку, то при повторных попытках я только хочу повторно подписаться на Observable-B и Observable-C.

Answer 1

Вы должны применить повтор к каждому Observable, чтобы повтор воздействовал на каждого из них независимо от других:

Observable.concat (
    Observable-A.retry(ERROR),
    Observable-B.retry(ERROR),
    Observable-C.retry(ERROR)
)