0
ответов

RxAndroidBLE - неразрешенная ссылка: `$ rxBleDevice` - характеристика чтения, возвращающая пустой ByteArray:

После установления соединения с моим предпочтительным устройством Bluetooth, я слушаю и жду каких-то нежелательных данных. Данные передаются с устройства регулярно, с произвольным интервалом времени. val charUUID ...
вопрос задан: 31 March 2019 01:05
0
ответов

RxJava2 + OkHttp Невозможно доставить исключение: время ожидания сокета

Я вижу следующее падение Crashlytics: фатальное исключение: io.reactivex.exceptions.UndeliverableException: java.net.SocketTimeoutException: истекло время ожидания соединения в io.reactivex.plugins ....
вопрос задан: 22 March 2019 08:15
0
ответов

Клапан для проверки того, что активен только один запрос

У меня есть RxJava2 Flowable цепочка, которая включает в себя некоторые тяжелые вычисления. Я хочу убедиться, что вся цепочка вызывается только по одному на запрос, и что в каждый данный момент существует не более одного активного запроса ...
вопрос задан: 18 March 2019 20:53
0
ответов

Каковы гарантии параллелизма для Flowable.merge ()

Я подробно изучил документацию оператора RxJava Flowable.merge (), но не могу найти нужную мне информацию. Мое понимание, после некоторых экспериментов, это то, что дано вверх по течению ...
вопрос задан: 7 March 2019 10:55
0
ответов

RxJS эквивалент RxJava для onBackpressureBuffer

В React Native я имею дело с событиями, генерируемыми при частоте 200 Гц через Bluetooth IoT. Мне нужно не отставать не более 2 минут. Есть накладные расходы, подталкивая их к JavaScript через ...
вопрос задан: 1 March 2019 08:45
0
ответов

Встроенная функция для глобального тайм-аута на Flowable

Читая документы об операторе тайм-аута, была ссылка на веб-сайт introtorx.com, который объясняет доступные операции тайм-аута. Второй пример в этом документе указывает, что есть оператор ...
вопрос задан: 17 January 2019 17:20
0
ответов

Могу ли я уведомить BehaviorProcessor из потока RxJava?

Я хотел бы получить ваш отзыв о коде ниже. Мне интересно, безопасно ли вызывать currentSession.onNext (result.session) из потока SessionManager.signIn. Моя первая интуиция состоит в том, чтобы ...
вопрос задан: 16 January 2019 16:29
0
ответов

RxJava2 успех всегда вызывается дважды

Я реализую архитектуру MVP с Retrofit и RxJava2 (с RxAndroid). У меня есть следующие настройки NetworkInterface.java, где вызовы модернизации лежат общедоступный интерфейс NetworkInterface {@ ...
вопрос задан: 16 January 2019 07:31
0
ответов

Когда звонить утилизировать и очистить CompositeDisposable

Мой вопрос может быть дубликатом Как использовать CompositeDisposable из RxJava 2? Но просят прояснить еще одно сомнение. Согласно принятому ответу // Использование clear очистит все, но может принять новое ...
вопрос задан: 22 December 2018 11:11
0
ответов

onComplete () не получает вызов с помощью DisposableSubscriber

Я получаю результат realm с помощью findAllAync с операторами rxjava, как показано ниже: Realm realm = Realm.getDefaultInstance (); realm.where (cls) .equalTo ("syncInfo.syncStatus", false) ....
вопрос задан: 13 July 2018 11:22
0
ответов

Когда использовать RxJava в Android, а когда использовать LiveData от Android Architectural Components?

У меня нет причины использовать RxJava в Android и LiveData от Android Architectural Components. Было бы очень полезно, если бы примеры использования и различия между ними были объяснены вместе ...
вопрос задан: 24 April 2018 16:36
0
ответов

RxJava Relay vs Предметы

Я пытаюсь понять назначение этой библиотеки Джейком Вартоном: https://github.com/JakeWharton/RxRelay В основном: субъект, за исключением случаев, когда нет возможности вызывать onComplete или onError. ...
вопрос задан: 5 August 2017 16:52
0
ответов

Как справиться без результатов с Android Room и RxJava 2?

У меня есть база данных с табличным контактом, и я хочу проверить, есть ли контакт с каким-либо номером телефона. @Query («ВЫБРАТЬ * ОТ КОНТАКТА, ГДЕ номер телефона =: номер») Текучий <Контакт> ...
вопрос задан: 31 July 2017 09:23
0
ответов

RxJava 2.x: я должен использовать Flowable или Single / Completable?

Я разрабатываю приложение для Android с использованием чистой архитектуры и перевожу его на RxJava 2.x. Я должен сделать несколько сетевых запросов к сервису мыла, поэтому я определил интерфейс API в модуле домена: ...
вопрос задан: 1 March 2017 10:17