reactivex

0зной

3ответ

Предельные действия с оператором rxJava и retryWhen

Мое приложение должно сделать две вещи в целом: Принимать только один запрос к сети, в то же время Retry, если запрос не удалось Вот как я его осуществить: public class RequestsLocker { private

2зной

2ответ

Фильтра наблюдаемый по наблюдаемым

Рассмотрят следующую упрощенную ситуацию: У нас есть наблюдаемые яблоки типа Наблюдаемого < Apple> Каждого объекта Apple, имеет метод isRotten(), который возвращает наблюдаемый type Observable < Boole

1зной

2ответ

Условная цепочка наблюдаемых

Я хочу асинхронно извлекать данные через несколько REST API. Я использую Retrofit на Android с расширением rxJava, т. Е. Я выполняю любой запрос GET, подписываясь на Observable. Как я уже говорил, у м

1зной

1ответ

Обращение с противодавлением без отбрасывания элементов или сериализация в RxJava

Короче говоря, есть ли решение для решения противодавления в RxJava, не прибегая к отбрасыванию элементов, сериализации или неограниченной буферизации? Рассмотрите следующую задачу в качестве примера

2зной

1ответ

TypeError: Невозможно прочитать свойство 'length' (машинописный/наблюдаемый/угловой2)

Что я хочу сделать довольно просто, у меня есть функция getListData, которая возвращает Observable Person[], и я хочу передать это html как Person [ ]. Так что я сделал это: @Injectable() export

0зной

2ответ

Как пользователь ReactiveX для выполнения async в последовательности

Как использовать ReactiveX для выполнения асинхронных вызовов в последовательности? I.e., выполнить второй вызов после завершения первого. Более конкретно, я работаю с RxSwift в прошивке, и asyncs я