AE
Size: a a a
Еx
S
S
Т
S
K
Т
AD
LC
BehaviorSubject чтобы на onNext запускала Maybe и дальше в цепочке получать результат обеих. При этом если Maybe вернёт ошибку то цепочка не отменится ?LC
.switchMap { city ->
repository.getCityServices(city.cityId)
.map { response -> response.content to city }
.doOnError(this::evaluateError)
.onErrorResumeNext { _: Throwable -> Maybe.empty() }
.toObservable()
}EMPTY если ошибка но всёравно цепочка заканчиваетсяEC
java.lang.IllegalStateException: more items arrived than were requestedDC
EC
DC
i
java.lang.IllegalStateException: more items arrived than were requestedi
i