[PanBaklazan]

#programowanie #rxjava

Mam taki problem: Posiadam dwa strumienie. jeden to np bazadanych drugie api
Te dwa strumienie łacze metodą concat(). Z np concat(baza, api)
z załozenia concat pierw nasluchuje pierwszy strumien do konca a dopiero pozniej kolejny.
U mnie strumienie są obserwowane obserwowane na watku w tle, a subscrybowane na watku UI.
Wszystko dziala pieknie jak oba strumienie przesylaja dane, lecz np jak odetne net, to baza ładnie konczy przygotowywac dane i wypycha je do watku UI, a watek w tle rozpoczyna pobieranie z API i odrazu napotyka problem, (brak netu) wiec wystawiam onError()... Po wystawieniu tego bledu onError jest wołany wcześniej niz onNext (z obserwowania bazy).
Co zrobic Mirki, zeby drugi strumien byl wykonywany DOPIERO jak wykonywanie pierwszego w całosci sie zakonczy (łacznie z wykonaniem metod onNext())

[PanBaklazan]

Chyba znalazlem rozwiazanie

You have to use observeOn(scheduler, true) to delay the error itself and keep the total event order

Kluczem jest true