Как отправить пользовательскую выбрасываемую карту через плоскую карту в RxJava на Android?
Итак, я использую flatMap с RxJava, чтобы связать некоторые вызовы API, которые возвращают Singles, и мне было интересно, как передать настраиваемый бросок методу подписки в методе flatmap в зависимости от моего собственного состояния.
Это приложение Android Kotlin, которое использует MVVM и RxJava2/RxAndroid для операций с данными. Я пытаюсь связать воедино кучу вызовов API, которые возвращают Singles, используя метод плоской карты. Каждый раз, когда я хочу вызвать новый метод API после предыдущего, я хочу проверить, был ли ответ на предыдущий вызов успешным. Если ответ на предыдущий вызов был успешным, я просто вызываю следующий метод API в плоской карте, и все хорошо, но если ответ на предыдущий вызов не был успешным, я хочу передать настраиваемый метаданный, который сообщает мне, где и почему операция была т успешно. Прямо сейчас в ситуации неудачного ответа я передаю Single с нулевым значением, но это просто дает мне нулевой указатель при подписке, а это не очень полезно.
dataManager.apiCall1(dataManager.sessionId!!)
.subscribeOn(schedulerProvider.io())
.observeOn(schedulerProvider.ui())
.flatMap{apiCall1Response ->
if (apiCall1Response.isSuccessful && apiCall1Response.body() != null) {
// First api call was successful, execute api call 2.
return@flatMap dataManager.apiCall2(apiCall1Response.importantVal)
} else {
// First api call failed
Single.just(null)
}
}.flatMap{apiCall2Response ->
if (apiCall2Response != null && apiCall2Response.isSuccessful && apiCall2Response.body() != null) {
// Second api call was successful, execute api call 3.
return@flatMap dataManager.apiCall3(apiCall2Response.importantVal)
} else {
// Second api call failed
Single.just(null)
}
}.subscribe({apiCall3Response ->
if (apiCall3Response != null && apiCall3Response.body() != null) {
// Success!
navigator!!.successful(response)
} else {
// Third api call failed, handle error
navigator!!.handleError(Throwable("Api call 3 failed."))
}
}, {throwable ->
// Failure, this is where I want to receive a custom throwable
// in case one of the responses were unsuccessful.
navigator!!.handleError(throwable)
})
Я ожидаю, что выбрасываемое сообщение будет чем-то вроде «apiCall1» failed, но выбрасываемое сообщение, когда apiCall1 терпит неудачу, — это просто NullPointer из-за Single.just(null), который я передаю.
Ответы 3
Используйте этот код
выбросить исключение NullPointerException из flatMap
и поймать ошибку на .onErrorReturn(throwable -> {//ваша работа здесь})
@Карсон Дж.
Вместо Single.just(null) используйте Single.error().
Например: Single.error<TypeHere>(RuntimeException("First api call failed"))
Для наиболее читаемого кода определите функцию расширения, подобную этой
private fun <T> Single<Response<T>>.decorateWithErrorHandling(): Single<T> {
return this
.onErrorResumeNext { throwable ->
// Map network layer exceptions, e.g. IOException to your specific "domain level" exceptions
Single.error(mapNetworkErrorToSpecificThrowable(throwable))
}
.flatMap { response ->
if (response.isSuccessful) {
Single.just(response.body())
} else {
Single.error(convertToSpecificThrowable(response))
}
}
}
Используйте это так:
apiCall1()
.composeWithErrorHandling().flatMap { result1 -> apiCall2(result1) }
.composeWithErrorHandling().flatMap { result2 -> apiCall3(result2) }
и Т. Д.