subscriber

0зной

1ответ

Абонент RxJava как параметр не работает, новая идентичная работа подписчика

Мы используем rxandroid:1.1.0 вместе с rxjava:1.1.2 в нашем приложении. Наш проект имеет подписчика RxJava, созданного таким образом: Действие Android создает подписчика. Когда пользователь удаляет эл

0зной

1ответ

Данные, полученные от Observer, не активируют подписчика в Rx Java

У нас есть сценарий, в котором мы выключаем устройство BLE Enabled, а затем экран Android App должен быть серым. Но когда выключить устройство BLE Enabled, вместо Greying, экран остается зависающим, и

1зной

1ответ

Наблюдаемый, кажется, не вызывает onNext через некоторое время

Я использую библиотеку RxAndroid для обработки списка элементов с использованием шаблона подписчика/наблюдаемого. Моя проблема заключается в том, что при обработке элемента есть индикатор выполнения,

-3зной

1ответ

Как настроить модель подписчика Mule Publisher

Как мне настроить модель подписчика Mule Publisher с помощью ActiveMQ? Я просматривал в Интернете полный пример, который прост и прост в использовании, но не смог. Все, что я хочу сделать, это отправи

1зной

1ответ

Как заблокировать очередь сообщений

Упрощенный: У меня есть очередь в activemq. Когда определенное сообщение считывается из очереди, я хочу заблокировать очередь, пока этот процесс не закончит работу над полученным сообщением. Дополните

3зной

3ответ

RxJava: Как подписаться, только если Observable Cold?

TL; DR: Как вы создаете Observable, который создает только подписку, если она холодно, и ставит в очередь любые другие вызовы подписки, когда это hot? Я хотел бы создать a Observable, который может вы

5зной

5ответ

Rxjava: Подписаться на конкретную тему

Я новичок в Rxjava. У меня есть следующий код: System.out.println("1: " + Thread.currentThread().getId()); Observable.create(new rx.Observable.OnSubscribe<String>() { @Override public