rx-java — все вопросы

1ответ
4 голоса
Почему оператор распространения Kotlin требует toTypedArray () при передаче простого аргумента vararg?
У меня есть приложение для Android, написанное на 100% на Kotlin. В моем классе модульных тестов у меня есть 2 тестовых наблюдателя, один наблюдает целые числа, другой - объекты: val conversati
1ответ
4 голоса
Функция расширения Kotlin для Observable <T> .subscribe не работает
Я пытаюсь написать функцию расширения для Observable.subscribe, которая автоматически регистрирует ошибки. fun <T> Observable<T>.subscribeAndLogE(onNext: Consumer<in T>): Disposa
2ответа
4 голоса
Сериализация rx-java, наблюдаемая по сети
Я пытаюсь сериализовать подписку для отправки по сети. Я использую Scala, и делаю что-то вроде этого: observable.materialize.subscribe{ n : Notification => sendToNetwork(n)} Однако я получа
1ответ
4 голоса
RxJava: Можете ли вы дать мне реальный живой сценарий, чтобы использовать flatMap вместо карты
Я не могу понять, когда использовать flatmap вместо карты, и не могу найти хороший пример. Можете ли вы придумать хороший сценарий для выбора плоской карты на карте? Благодарю.
1ответ
4 голоса
Потребление значений одновременно выдается наблюдателем
Я изучаю реактивное программирование с использованием RxJava и хочу одновременно использовать извлеченные значения без блокировки в одном потоке выполнения. Observable .interva
1ответ
4 голоса
RXJava - разделить и объединить наблюдаемое
Я новичок в RxJava и мне нужна помощь /руководство по следующим действиям:    Мне нужно получить два значения из Observable       строка    Список <.ObjectA>    Затем мне нужно примени
1ответ
4 голоса
Observable.interval () с initialDelay
У меня есть служба опроса, которая реализована с использованием Observable.interval(POLL_INTERVAL, Seconds). Это работает нормально, но я хотел бы, чтобы первая задержка была 0, я имею в виду, что я
2ответа
4 голоса
RxJava onErrorResumeNext планировщик
У меня есть наблюдаемая, которая может потерпеть неудачу со специальным исключением, и в этом случае я хочу показать диалог с кнопкой повтора. Я видел этот ответ, но он не совсем так, как я хочу.
1ответ
4 голоса
Модификация наблюдаемых объектов и доступ к коду ответа в успешном запросе
Я использую Retrofit и RxJava. Я знаю, что могу обрабатывать ошибки таким образом , поэтому я могу делать вещи с соответствующими ошибками. Теперь у меня есть вызов API, и мне нужно получить код
1ответ
4 голоса
RxJava: Наблюдение за сообщениями, испускаемыми из сокета
Я все еще пытаюсь выучить RxJava. Есть одна вещь, которую я просто не могу обернуть головой прямо сейчас. В каждой статье, которая пыталась научить меня, как использовать Rx, было показано, как созд
1ответ
4 голоса
Объедините два наблюдаемых логических значения с ObservableBoolean или Observable <Boolean>
В JavaFX вы можете сделать следующее, чтобы объединить два наблюдаемых логических значения: BooleanProperty imagesDownloaded = new SimpleBooleanProperty(false); BooleanProperty animationComplete =
1ответ
4 голоса
Преобразование RxJava в RxScala
Есть ли способ использовать как RxJava , так и RxScala в одном проекте? import rx.lang.scala.{Observable => ScalaObservable} import rx.{Observable => JavaObservable} У нас есть модуль,
1ответ
4 голоса
Правильный способ использования RxJava + Retrofit 2
У меня есть такой JSON: { "success":true, "data":[ { "id":"29", "name":"\u0420\u0435\u0441\u0442\u043e\u0440\u0430\u0446\u0456\u044f \u0411\u0430\u0447\u0435\u0432\u0441\u044c\
2ответа
4 голоса
CombineПоследние и холодные наблюдаемые
Учитывая следующий код: Observable<String> obs1 = Observable.just("1", "2", "3"); Observable<String> obs2 = Observable.just("a", "b"); Observable.combineLatest
3ответа
4 голоса
Исполнитель задачи в Java, который возвращает первое завершающее задание
Я хочу реализовать что-то, что получило бы коллекцию рабочих (вызываемых элементов), запустило это параллельно в пуле потоков, и когда самый быстрый работник вернул результат, изящно завершил работу
1ответ
4 голоса
RxJava подписывайтесь на наблюдаемую блокировку
Я бы хотел добиться следующего: String result = myObservable.toBlocking().first(); то есть. это как обычный вызов функции. Однако этого никогда не происходит, потому что вам нужно подписаться н
1ответ
4 голоса
Как утверждать, что Завершенный был подписан /завершен (RxJava2)
У меня проблемы с определением того, подписан ли на Completable в моих тестах, например: interface IWebApi { Observable<Data> download(); } interface IDataRepository { Completable i
1ответ
4 голоса
RxJava1 против Rxjava2: исключение в onNext
При выполнении следующего в RxJava1 исключение в onNext будет перенаправлено в ошибку onError того же подписчика: Observable.from(Arrays.asList("1", "22", "333", "4444")).subscribe(new Subscri
2ответа
4 голоса
Отделка заметная
Можно ли украшать Observable<>, Single<>, Maybe<>, Flowable<> в гх-Java? Например. как это: public final class NonEmptyStringSource extends Observable<String> {
2ответа
4 голоса
RxJS CombineПоследний оператор странное поведение
У меня есть запрос, связанный с оператором RxJS CombineLatest. Я изменил пример, приведенный в https://www.learnrxjs.io/operators/combination/combinelatest.html следующим образом: //timerO
1 2 3 4 5

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132