Questions tagged [rxjava]

Java реализация ReactiveX, являющегося API для асинхронного программирования посредством наблюдения за потоками событий

Основной сайт по ReacticeX, содержащий документацию по API.

Репозиторий RxJava на GitHub.

Проект RxMarbles - наглядная, интерактивная, демонстрация работы функций ReactiveX.

242 questions
5
votes
1 answer

Различие между subscribeOn и observeOn методами

В чём заключается различие между subscribeOn и observeOn методами? Правильно ли я его понимаю? Вот то, как я это понимаю: subscribeOn определяет поток по умолчанию для Observable после его создания (в случае, если его нужно выполнять не в текущем…
Ksenia
  • 10,679
1
vote
1 answer

RxJava: как подписаться на данные из другого потока?

Хочу подписаться на ответ, полученный на запрос из сети. Допустим у меня есть такой интерфейс: interface Net { // Посылает запрос в сеть, а когда приходит ответ // дергает callback в своем сетевом потоке void…
1
vote
1 answer

Как получить List из Flowable RxJava

Подскажите, пожалуйста, как получить List из Flowable? Есть метод, который возвращает List. Внутри него идёт запрос к бд, через метод, который возвращает Flowable>. Как конвертировать его в массив строк?
0
votes
1 answer

rxJava, синхронизировать несколько потоков с потоком триггером

Есть несколько обсерверов http запросов, запускающихся при старте приложения параллельно, порождающие некоторый поток сущностей для дальнейшей обработки(doSomething). Допустим request1, request2, request3 Есть один обсервер, запускающийся так-же при…
rjhdby
  • 13,850