Всем привет.
Вопрос адресую людям, разбирающимся в rx.
Задача: нужно сделать запрос в сеть.
В случае ошибки запроса, нужно сделать другой запрос. И только в случае успеха выполнения второго запроса,
передернуть первый запрос.
Сделал примерно вот так, но это не работает: вешает приложение, хотя okhttp в логах показывает,
что запрос из fun2 отрабатывает и прилетает 200 от сервера.
Грешу на blockingGet. Но если не блокировать запрос, а пользоваться subscribe({},{}), то происходит гонка,
и логика ломается.
Прошу дать советы, подсказать, ибо мои познания в rx пока достаточно поверхностны.

private fun fun1() {
 var disposable: Disposable? = null
 disposable = interactor.updateDictionary()  
   .doFinally { disposable?.dispose() }
   .subscribe(
     {},
     { error ->        
       if interactor.fun2()
         fun1()        
     }
   )
}

fun fun2(): Boolean {
 var success = false
 try {
   val updateValue = updateFun()
     .blockingGet()    
   success = true    
 } catch (exception: Throwable) {
   Timber.e(exception)
   success = false
 }
 return success
}

Всем привет.
Адресую разработчикам с опытом в rxjava
Описание ситуации:
Авторизация на сервере у нас с двумя токенами.
В случае 401 я должен запустить логику по обновлению ACCESS_TOKEN с помощью REFRESH_TOKEN (openid authentication вроде бы это правильно называется).
В сеть лазаю с помощью ретрофита в связке с rxjava2.
Примерно так:
@GET("api/v1/drivers/current")
fun getCurrentDriver(): Single<DriverData>

Методы для вылазки в сеть возвращают либо Single, либо Completable.
Идея такова, что я хочу написать одну цепочку по обновлению токенов, и в случае 401 приклеить
её к каждому методу-запросу в сеть
Подскажите, пожалуйста, как правильнее это сделать и вообще правильная ли задумка.

Сейчас в случае 401 ошибки я в интерцепторе пораждаю кастомное исключение, которое обрабатываю в onError каждого похода в сеть.
Вызываю метод по обновлению токенов, который должен возвращать Boolean. И  в случае успешного обновления внутри OnError запускаю рекурсивно этот же метод.
Мало того, что это выглядит не очень, так еще и для того, что бы реактивный метод по обновлению токенов возвращал Boolean приходится блокировать поток с помощью оператора blockingGet

Буду рад советам. Спасибо заранее.

Если я правильно понял задачу то okhttp сам всё это делать умеет , а посколько retrofit использует okhttp то пляски с rx вам не нужны

У кого какие варианты такое сделать

Добрый вечер. Помогите, пожалуйста, с решением проблемы:
Есть interactor через который идёт связь с api. Мне нужно вывести варианта автозаполнения, как это сделано в google по мере набора текста.
RxJava находится в presenter и сейчас делается запрос через Single.fromCallable(), я понимаю что решение неправильное. Нужно через Observable сделать. Но не понимаю как сделать запрос в Observable (как ему передать новое знание вручную, чтобы он вызвал onNext() у Consumer)

Гайс, всем привет, мне нужн сделать метод в бекграунде который возвращает мне что-либо  (НЕ ентити rxJav’ы), и вернуть это в мейн тред, что мне лучше всего использовать?
Думал Completable.fromAction() Но в этом случае подписчик не получет ничего обратно

Ребят, а как сделать обертку асинхронную над методом, который вызывается много раз подряд и обращается к серверу, получить нужно только ответ последнего обращения (остальные игнорировать/блокировать)