Wpis z mikrobloga

najprościej wydziel to na początek na metody zwracające Single jeśli spodziewasz się pojedynczego elementu, możesz na observable zawołać firstOrError(zawoła onError gdy najdzie 2gi element - kontrakt single gwarantuje dokładnie success/error)

andThen nie wiem co to za operator, ale pewnie zamieniłbym to na zwykłe flatmap i mapował rezultat jakiego potrzebujesz

tak przy okazji - może jakiś retry leci pod spodem w tych świńskich repozytoriach? ( ͡° ͜ʖ ͡°)
@Rubajticos: flatMapCompletable pozwala na mapowanie na Completable. W twoim przypadku dla każdego elementu zwróconego z piggyWithContributionsRepository.getOne() zostanie wykonany piggyWithContribitions.getPiggy().setActualAmount. Completable różni się od Flowable tym, że nie zwraca elementów tylko Success lub Error.
Dlaczego to wykonuje się w kółko?
Podejrzewam, że piggyWithContributionsRepository.getOne() to jest subskrybcja na repozytorium opartej o bazę danych przy wykorzystaniu Room. Jedna z akcji piggyWithContribitions.getPiggy().setActualAmount() lub piggyRepository.updateWithCallback() prawdopodobnie modyfikuje bazę, a to powoduje, że piggyWithContributionsRepository.getOne() publikuje