Я пытаюсь принудительно выдать ошибку во время поддельной загрузки с помощью RxJava:
disposable.add(fakeRepo.downloadSomething()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ a: String -> finished() },
{ b: Throwable? -> showError() }
))
fun downloadSomething(): Single<String> {
return Single.just("")
}
Я нашел решения только с onNext, но я не хочу этого в своем коде.
Что я должен сделать, чтобы вызвать showError()?
В настоящее время я всегда получаю finished()
да, сбросить исключение
Просто используйте Single.error:
http://reactivex.io/RxJava/javadoc/io/reactivex/Single.html#error-java.lang.Throwable-
public static Single error(Throwable exception) Returns a Single that invokes a subscriber's onError method when the subscriber subscribes to it.
Выбросить исключение?