спасибо, через onErrorResumeNext получилось, но мне пришлось самому писать после completable свой вызов single снова, элегантнее можно это сделать? что бы после completable сам снова автоматом попробовал последний запрос

а вопрос случаем не связан с протуханием токена? для этого другие способы есть. А что мешает написать функцию, которая принимает на вход тот же Single<T> и внутри в ней будет уже логика перезапроса в случае ошибки? правда не заню насколько этот подход хорошо и подойдет вам - первое что на ум пришло, но это если я правильно кейс ваш понял(в моем понимании у вас не в одном месте такая логика нужна)

не это не токен, ну лан спасибо

retryWhen можно

!спам

Наверняка уже реализовывали такую логику: есть getData() : Single<MyData> от ретрофита, с помощью которого  можно сделать запрос на сервер, так вот хочу этот запрос делать каждую минуту. Правильно понимаю, что одинм из лучших решений будет:

Observable
    .interval(1, MINUTE)
    .switchMap(getData())

Блин, не могу справится с RX .NET
Кто нибудь шарит?
Смотрите, у меня есть несколько VM калькуляторов, у каждой из которых есть реактивное свойство bool HasErrors.
Мне нужно блокировать кнопку, в том случае, если хоть у одного из калькуляторов это свойство выдало false.

Я думал это работает. И оно в дейсвительности работает во многих случаях

Но за счет слайдинга: .Buffer(PlaceCalculators.Count, 1) в некоторых случаях это не работает все таки

Я думаю, что эту проблему можно решить совершенно по другому, но не пойму как

Чтобы было понятно:
x.WhenAnyValue(x => x.HasErrors, hasErrors => !hasErrors) <— возвращает IObservable<bool>

тем самым вызов:
.SelectMany(x => x.WhenAnyValue(x => x.HasErrors, hasErrors => !hasErrors))
из множества IObservable<bool> делает одну IObservable<bool>

Hello there
RxJava, Android
Задача:  читать inputStream у процесса и отдавать выше, с повторением данных
Решение: создаём Observable.create(ObservableOnSubscribe), где внутри логика чтения из процесса
Создаём ReplaySubject.create()
Observable.subscribeOn(IO).subscribe(subject)
Данные передаются
Нужно остановить чтение данных при отписке в верхних слоях
Как это сделать?
Вызывать onComplete у subject?
Или хранить observable и вызывать что-то у него?

Народ, бывает какая нибудь реализация CombineLatest с динамическим списком IObservable ?
Я заранее не знаю количество в массиве моих IObservable<T>, но хочу применить с этим списком логику CombineLatest

как сделать?

Observable.just(true).repeatWhen(t->t.delay(25, TimeUnit.MINUTES)).subscribe(b->{method();});

В данном примере мы можем повторять действие раз в 25 минут)
При этом как только вызывается эта строчка кода - действие стартует.

Как отменить первичный старт? Чтобы первый старт был через 25 минут?

замени на interval. одна из перегрузок позволяет задать первую задержку

Угу,спасибо)

Продам спамер-рассыльщик по Телеграму.
Связь в @se_nator

https://youtu.be/ILWEf7SWEJI