Форум программистов, компьютерный форум, киберфорум
Наши страницы
Программирование Android
Войти
Регистрация
Восстановить пароль
 
Tajfu
0 / 0 / 0
Регистрация: 04.09.2019
Сообщений: 20
1

RxJava Observable.from из BroadcastReceiver

10.09.2019, 11:32. Просмотров 208. Ответов 4
Метки нет (Все метки)

Здравствуйте.
Недавно начал внедрять rxJava и столкнулся со сложностью:
Есть BroadcastReceiver (или любая другая периодически срабатывающая функция), необходимо при каждом ее срабатывании формировать Next.
У Observable.from... есть разные методы но что-то не увидел как реализовать это.

ПС.
Работать естественно должно в своем потоке не тормозя ui. и желательно прослушке самой умереть если не будет подписчиков.
0
QA
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
10.09.2019, 11:32
Ответы с готовыми решениями:

IntentService -> Singleton Observable <-> Activity Observer можно ли?
Вобщем у меня есть IntentService, который получает данные, отправляет в синглтон и вырубается, до...

RXJava 2
Всем привет! Посоветуйте хорошие статьи по RXJava 2 и применение этого в андроиде(можно...

Rxjava
Изучаю rxJava по книге &quot;Реактивное программирование с применением RxJava&quot; Томаш Нуркевич и Бен...

RxJava запрос данных
Вопрос возник как лучше делать в ситуации, когда нужно запросить данные и для каждого элемента...

Остановка выполнения RxJava
В процессе изучения RxJava + Retrofit уперся с вопросом как правильно завершить выполнение RxJava?...

4
ExFau$t
924 / 733 / 217
Регистрация: 08.05.2012
Сообщений: 3,534
10.09.2019, 12:12 2
При каждом срабатывании создавать поток и формировать что угодно.

Добавлено через 2 минуты
И да, если создавать много тем с одинаковым вопросом - ответ от этого не изменится.
0
Tajfu
0 / 0 / 0
Регистрация: 04.09.2019
Сообщений: 20
10.09.2019, 12:34  [ТС] 3
"При каждом срабатывании создавать поток и формировать что угодно."
А точнее? Как добавить в уже существующий поток событие при отработке
@Override
public void onReceive(Context context, Intent intent)
0
ExFau$t
924 / 733 / 217
Регистрация: 08.05.2012
Сообщений: 3,534
10.09.2019, 12:59 4
Java
1
2
3
4
5
6
7
8
Flowable busFlowable = rxBus
                .asFlowable()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnNext(event -> {
                    
                    }
                });
0
Tajfu
0 / 0 / 0
Регистрация: 04.09.2019
Сообщений: 20
10.09.2019, 13:06  [ТС] 5
это обработка пришедшего события в головном потоке...
А что генерирует само событие? onNext() то где?
0
10.09.2019, 13:06
Answers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
10.09.2019, 13:06

RxJava вернуть данные назад
Создал метод generatePlayer(String, String, ApiService) в нем использую запросы, а так же метод...

Поиск в Realm +RxJava+RxBindings
Есть код поиска,но мне не нравится его поведение, есть ощущение что ищется только 1 раз и все, в...

Цепь запросов rxjava + retrofit
Мне нужно сделать 2 разных запроса через retrofit. Один на авторизацию а второй на получение...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
5
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2019, vBulletin Solutions, Inc.