Как создать исключение с помощью RxJava без OnNext

Я пытаюсь принудительно выдать ошибку во время поддельной загрузки с помощью 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()

Выбросить исключение?

LppEdd 08.04.2019 23:00

да, сбросить исключение

purcha 08.04.2019 23:04
0
2
41
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Просто используйте 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.

Другие вопросы по теме