я каждый раз читаю, думаю, что понял, использую, всё работает, а потом ХОБА

всё прекрасно работает. А совет не нужно пропускать мимо ушей. Там ответ

я ничего стараюсь не пропускать мимо ушей) Ясен фиг, оно не просто так решила не работать, а я что-то не так понял и подход, который до этого работал, перестаёт работать.

Ребят, есть какой нибудь оператор в rx java, чтобы падала ошибка если значение не придёт в первые N секунд/миллисекунд?

timeout (ого!)

Спасибо

Хай. Кто-нибудь делал ajax реквесты на RxJS?

Не знаю как сделать обнавление инфы с реквестов

const users: Observable<Types.User[]> =
      ajaxPost (host + "/users") (Types.usersReadRequest)
        .pipe (
          Rx.catchError (err => (console.log (err), of (err))),
          Rx.map (({ response }) => response)
        )

Этот Observable в State'е лежит

Мне нужно в определенный момент обновить юзеров

Как я могу кинуть ошибку, чтобы globalError не отработал ?

Если я правильно помню global error отрабатывает только когда ты не хендлишь ошибку. То есть тебе нужен onError subscriber

subcribe({<onResult>}, {<onerror>})

День добрый. Вопрос - можно ли добавить кондишн который бы можно было бы проверять несколько раз с задержкой? Есть значение параметра которое меняется во времени - оно и является условием. Во время вызова подписки хотелось бы проверять этот параметр и в одном случае - останавливать цепочку с задержкой, повторять проверку, и в успешном случае пробрасывать значение дальше, в не успешном ошибку. Реализовал решение которое вставляется посреди цепочки, но оно не очень нравится, выглядит следующим образом:

fun Single<String>.resolveCondition(): Single<String> {
    return this.flatMap { value ->
            if (checkCondition(value)) {
                source().delay(DELAY, TimeUnit.MILLISECONDS).resolveCondition()
            } else {
                Single.just(value)
            }
        }
    }

fun source(): Single<String> {
 return Single.fromCallable{
  source.value
 }
}

fun Single<String>.resolveCondition(): Single<String> {
    return this.flatMap { value ->
            if (checkCondition(value)) {
                source().delay(DELAY, TimeUnit.MILLISECONDS).resolveCondition()
            } else {
                Single.just(value)
            }
        }
    }

fun source(): Single<String> {
 return Single.fromCallable{
  source.value
 }
}

имхо норм решение ток поменяй  delay на delaySubscription

У maybe есть flatMapSingleElement. А есть что то вроде flatMapEmpty?

Что то не могу найти

у мейби есть обычный flatMap но с функцией от элемента, функцией с ошибкой и консьюмера емпти

ой, соплаер

FlatMap работает только на элементы