Вопросы с меткой [rxandroid]
RxAndroid — это расширение RxJava, написанное специально для Android, которое включает в себя специальные обвязки вокруг RxJava, делающие вашу жизнь проще.
70
вопросов
1
голос
0
ответов
26
показов
Статус подключения к серверу с помощью rxjava в Android
Имею подключение по websocket
object StompWrapper {
private var emitter: ObservableEmitter<Event>? = null
init {
val client = OkHttpClient.Builder().build()
val stomp = ...
0
голосов
1
ответ
45
показов
Как сделать вызов асинхронным rxJava
У меня сейчас стоит задача получить список данных из интернета, через retrofit. И если код ответа не успешный(200), то взять этот список данных из бд(room).
Как мне сделать это правильно с rxJava?
Я ...
0
голосов
1
ответ
54
показа
RxJava сортировка списка по одну из эллементов
Имею json из такими строками как title, time, click_url, img, type, top и тд.
Я получаю список эллеметов со строками которые я описал выше.
Мне нужно Получить список эллеметов который будет иметь ...
0
голосов
2
ответа
53
показа
Как вызвать onError после filter()
Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
1
голос
1
ответ
64
показа
Реализация мгновенного поиска c RxJava
Пытаюсь делать в своем приложении мгновенный поиск пользователей из удаленной БД с RxJava. Следуя по одной статьи получилось сделать так: Сначала мне приходится получить всех пользователей,а потом ...
0
голосов
0
ответов
103
показа
Получаю java.io.IOException: unexpected end of stream on http:/ когда пытаюсь загрузить файл из сервера
Привет получаю ошибку (java.io.IOException: unexpected end of stream on http:) при попытке загрузить файл(.txt) из сервера
вот код сервера
@RestController
public class DownloadDbController {
@...
0
голосов
2
ответа
1k
показов
В чем отличие Single от Observable в RxJava?
Друзья! В чем различие Single и Observable? Не понятно, когда использовать Observable вместо Single, во всех обычных операциях получение с БД данных или из сети всегда один запрос, а значит всегда ...
0
голосов
1
ответ
151
показ
Выполнение метода через промежуток времени rx java
Есть задача отправлять данные по Bluetooth при помощи библиотеки RxAndroidBle.
Я написал метод который отправляет данные. Выглядит он сейчас вот так:
private void sendMessage(UUID uuid, String ...
0
голосов
1
ответ
94
показа
ProgressBar пока нет данных
Изучаю rxJava, и вот я задался вопросом как можно показывать ProgressBar если источник данных не излучил данные за 300 миллисекунд, и по мере наступления собственно убирать Progressbar.
1
голос
1
ответ
56
показов
Комбинация нескольких методов в RXJava2
Дело в том, что мне необходимо одновременно подтягивать данные из локальной базы, с сервера, при этом проверять подключение к интернету.
Без проверки интернета получается легко. Но при отключении ...
2
голоса
1
ответ
290
показов
RxJava и Retrofit. Автоматическое обновление данных из сети
Всем привет!
Мне нужно при запуске приложения получить данные из БД и отобразить их на экране.Соответственно при изменении данных в БД поменять их и на экране(С этим я справился). Так же параллельно ...
0
голосов
0
ответов
66
показов
Код ревью тестового проекта Android Dev
Я начинающий Android разработчик и пытаюсь устроиться на работу. На одном из собеседованиях мне дали тестовое задание:
Требуется разработать клиент, отображающий погоду на неделю для указанного ...
1
голос
1
ответ
177
показов
Android, отписка от BehaviorSubject
У меня есть BehaviorSubject, назначение которого - наблюдать за int переменной:
private BehaviorSubject<Integer> source = BehaviorSubject.create();
В onCreate я подписываюсь на него:
source....
1
голос
1
ответ
168
показов
RxJava очередь запросов или запрос в цикле
Использую Rx, обращаюсь в сеть и в запросе передаю параметр.
этих параметров несколько, List<String> paramsValue;
Выполняю так:
for(String p : paramsValue)
Flowable f = QRequests.get(p);
...
2
голоса
1
ответ
65
показов
Проблемы с переходами между фрагментами
Есть 3 фрагмента, первый (с которого запускается приложение отображается нормально), когда свайпаю, чтобы перейти на следующие фрагменты, то информация внутри них не отображается.Но вот что заметил, ...
0
голосов
1
ответ
219
показов
RxJava merge параллельное выполнение
Не удается запустить параллельно два Observable через merge.
class MyExample {
//Создание observable
public static Observable<String> createObservable(String name){
return ...
0
голосов
1
ответ
88
показов
Заполнить spinner данными из сети (json)
Нужно из json получить список категорий и потом поместить в спиннер. (Нужно для поиска товара: категория + текст)
Делаю так :
Сеть. Retrofit +rxJava
ViewInterface mvi;
@Override
public void ...
1
голос
1
ответ
38
показов
Получение результата запроса RxJava2 + Room
Не могу разобраться с получением данных после запроса, в конечном итоге необходимо вернуть объект Note, но как это написать не понимаю, бьюсь над проблемой не первый день.
При всех попытках получить ...
0
голосов
2
ответа
113
показов
RxJava2. Как вернуть Observable<Object> из метода, который возвращает void?
Метод takePicture(...) из android.hardware.Camera имеет тип возвращаемого значения void
public final void takePicture(ShutterCallback shutter, PictureCallback raw, PictureCallback jpeg) {
...
1
голос
2
ответа
80
показов
При добавлении в Room кидает ошибку
хочу получить данные с помощью retrofit и сохранить в Room.
Но возникает ошибка
Type mismatch: inferred type is Disposable! but Article was expected
Как можно исправить ошибку?
class MainActivity :...
0
голосов
1
ответ
45
показов
Как в rxJava получить объекты класса по отдельности
Начал потихоньку, изучать rxJava.
Есть класс Page
public class Page {
public String value1;
public String value2;
...
public Page(String value1, String value2) {
this.value1= ...
3
голоса
1
ответ
188
показов
Android EditText и Rx
Помогите пожалуйста, есть несколько EditText. Отслеживаются изменения в них. И в зависимости какие данные введены изменяются другие EditText. Как можно блокировать наблюдения за определенными EditText,...
0
голосов
0
ответов
65
показов
Как правильно собрать Maybe RxJava2?
Работаю с Room есть вот такой метод
@Query("SELECT * FROM mytable WHERE pnr = :iPnr")
abstract Maybe<UserPnrDbObject> getBy(String iPnr);
и есть вот такой метод
public Maybe<UserActivePnr&...
0
голосов
1
ответ
19
показов
Таймер получения эмиссии
Есть источник данных.
Требуется выполнять действие если источник данных не эмиттил айтем за 3 секунды.
введите сюда кодLog.d("MAESTRO", "before: ");
ConnectableObservable.just(...
0
голосов
1
ответ
63
показа
Как собрать Maybe<List<User>> из Maybe<User>?
Есть у меня метод
Maybe<User> getUser(int iId){}
и есть метод
Maybe<List<User>> getUsers(List<Integer> iIds){}
Вопрос: как реализовать этот метод?
0
голосов
1
ответ
192
показа
Задача на rxJava
У нас есть Observable<Int> который эммитит разные числа. Нам надо встать между Observable и подписчиком и смотреть когда к нам в onNext приходит число "x" то мы увеличиваем счетчик на единицу и ...
3
голоса
2
ответа
556
показов
Как выполнить метод после нескольких запросов?
Хотел бы реализовать: По нажатию кнопки происходит загрузка информации с API и добавление (Если пустая)/обновление (Если заполненная) этой информации в базу данных.
Более подробно: Использую Retrofit ...
5
голосов
0
ответов
119
показов
Как правильно составить очередь в rxJava и ретрофит
Я использую ретрофит2 и рх2
Мое приложение раз в секунду делает запрос на сервер
Я хочу эти запросы поставить в синхронную очередь, так чтоб они выполнялись один за другим по мере поступления в ...
0
голосов
1
ответ
52
показа
Получение объекта с Retrofit RxJava
Имеется метод requestQuery(String query) основная задача которого состоит в том, чтобы возвращать список объектов List<QueryData> после их загрузки Retrofitom. Объект Query имеет всего один ...
1
голос
1
ответ
119
показов
Как сделать итерацию с индексом в RxJava2?
Вот есть у меня такой метод, который я хочу переписать с Rx
public ArrayList<Integer> getAllQuestionsPositionsByType(eQuestionFieldType iType)
{
ArrayList<Integer> result = new ...
0
голосов
1
ответ
73
показа
Как получить boolean используя RxJava2?
Вот есть такой метод
private boolean checkIfQuestionIsDisableCheckbox(ServicePartFormQuestion iQuestion)
{
boolean result = true;
if (iQuestion.getAnswerFieldType().isCheckbox())
{
...
0
голосов
1
ответ
105
показов
Почему получаю 'original thread' ошибку? RxJava2
Вот есть у меня Flowable на который я подписываюсь вот так
private void setListeners()
{
Flowable<String> flowable = createTextChangeFlowable();
mDisposable = flowable....
1
голос
1
ответ
125
показов
Как создать Observable в одном потоке, а подписаться в другом?
Использую com.google.android.gms.vision.barcode.Barcode;. Метод receiveDetections вызывается постоянно при запуске сканера. Как я понял, он выполняется не в потоке main где вызывается setProcessor. Я ...
2
голоса
1
ответ
144
показа
Как обработать правильно ошибку RxJava2
Вот есть такой код
private long getEntireElementsCount(Map<?, Integer> iMap)
{
return Observable.fromCallable(iMap::values)//
.onErrorReturnItem(new ArrayList<>()...
1
голос
0
ответов
44
показа
Почему получаю последний query, RxJava2
Использую обычный TextWathcer , чтоб собрать Flowable вот так
private Flowable<String> createTextChangeFlowable()
{
Flowable<String> flowable = Flowable.create(iEmitter ->
{
...
3
голоса
1
ответ
1k
показов
Как превратить EditText в поток данных для RxJava2?
Начал постепенно переходить на реактивное программирование с замечательным фреймворком RxJava 2 и заинтересовал простейший пример создания потока в динамическом стиле. К сожалению, не считаю пример ...
2
голоса
0
ответов
96
показов
Можно ли написать с RxJava2 оператор if/else с условиями на нескольких уровнях
Вот есть такой кусок кода
if (shouldSearchForCode)
{
if (iFilterableObject.getStorageRoomCode().equals(SupergasApplication.getInstance().getUser().getUserName()))
{
...
0
голосов
1
ответ
108
показов
Почему `onErrorReturnItem()` все равно возвращает `NullPointerException` RxJava2?
Есть вот такой метод
private Single<List<String>> getOtherEmployeesSingle()
{
return Observable.fromIterable(mFilteredOtherEmployees)//
.map(//
...
2
голоса
1
ответ
41
показ
Как ловить ошибку в таком примере Rx2
Вот есть такой код
return Observable.just(new Date())//
.map(//
iEndDate ->
{
Date ...
0
голосов
1
ответ
400
показов
Как поставить задержку на Observable RxJava2?
Вот есть был такой метод
public List<String> search(String iQuery)
{
try
{
Thread.sleep(700);
}
catch (InterruptedException iE)
...
1
голос
1
ответ
96
показов
Как выполнить проверку на null в rxjava2
Вот есть такой метод
public void updateDependedQuestionsIfNeeded(ServicePartFormQuestion mCurrentServicePartFormQuestion)
{
try
{
if (mCurrentServicePartFormQuestion != null &&...
3
голоса
1
ответ
119
показов
Как написать с помощью RxJava2 простую итерацию как в примере
Вот есть такой метод который я использую для того, чтоб при получении ответа с сервера сделать парс сразу в енам
@JsonCreator
public static eTaxCode getTaxCodeByIdOrDefault(int iTaxCode)
{
...
4
голоса
1
ответ
468
показов
Как правильно заменить AsyncTask с помощью RxJava2 и RxAndroid2
У меня есть AsyncTask, который я хочу переделать в Rx
Вот так выглядит мой AsyncTask
new AsyncTask<Void, Void, Void>()
{
ArrayList<CallServiceCode> undoneServiceCodes = new ...
1
голос
1
ответ
76
показов
Как удалить из HashMap RxJava2 правильно?
У меня есть Map<CallServiceCode, List<CallServicePart>> и есть текущее значение ключа CallServiceCode mCurrentCallServiceCall
Мне нужно получить value по этому mCurrentCallServiceCall ...
2
голоса
1
ответ
166
показов
Как собрать Map используя RxJava2 и RxAndroid?
Есть у меня полный список обьектов который мне нужно отсоритировать по условию, в итоге я получаю список отсортированых обьектов, каждый обьект в этом списке содержит еще список который тоже нужно ...
2
голоса
1
ответ
61
показ
Можно ли с RxJava2 получить свой обьект?
Хочу разобраться с rx и вот такой вопрос у меня сейчас есть у меня такой метод
private boolean isThereBlanksForSing()
{
boolean result = false;
for (CallServiceCode tmpCode : ...
0
голосов
1
ответ
64
показа
Ошибка в результате отправки запроса на север retrofit + rxjava. Error Expected BEGIN_ARRAY but was BEGIN_OBJECT at line 1 column 2 path $
{
"contacts": [
{
"id": "c200",
"name": "Ravi Tamada",
"email": "ravi@gmail.com",
"address": "xx-xx-xxxx,x - street, x - ...
6
голосов
1
ответ
546
показов
Асинхронное чтение/запись в Realm используя RXJava 2
Моя первая реализация асинхронной работы с помощью RXJava 2.
Цель:
Получить json данные с сервера библиотекой Retrofit2. Если успешно, то записать в Realm и сразу после записи получить обратно ...
2
голоса
2
ответа
832
показа
Почему вылетает :OnErrorNotImplementedException: The mapper function returned a null value
Пытаюсь получить данные из БД, но вылетает ошибка
io.reactivex.exceptions.OnErrorNotImplementedException: The mapper function returned a null value.
Класс данных, в который должен вкачаться ...
1
голос
1
ответ
116
показов
Насколько мой код приемлемый
Я только начал изучать Android и Rx, ещё не знаю всех тонкостей. Хотелось бы узнать, насколько ужасный блок кода.
val room = Room.databaseBuilder(applicationContext,
AppDatabase::...