Articles of rx android

OnComplete никогда не вызывал с toSortedList () и groupBy ()

В настоящее время я использую библиотеку Android-ReactiveLocation ( Github ). LastKnownLocationObservable ( Code ) работает по назначению. Я использую flatMap для извлечения соседних станций из db и (из-за сферы) Я создаю модель из данных. Поэтому у меня есть список элементов, и я создаю новый Observable в flatMap с Observable.from(data) . Затем я хочу сортировать местоположения, […]

Как преобразовать многие AsyncTasks в Rx Observables в Android?

Я использую API-интерфейс Facebook для поиска пользователей, которым нравятся мои сообщения. Вся логика реализуется в несколько шагов: Найти все сообщения от asus Преобразуйте этот AT в Rx.Observable Карта наблюдений GraphResponse to List (Post is POJO) Вызывайте оператор FlatMap и в нем метод вызова тела, который выполняет итерацию каждого сообщения и делает asyncTask, а затем преобразовывает […]

Как получить Flowable <List <Foo >> из объекта «Bar» с отношениями «один ко многим» «Foo» с использованием realm и Rxjava

Скажем, у меня такой класс модели. Я копирую отсюда. open class Person( @PrimaryKey var id: Long = 0, var name: String = "", var age: Int = 0, var dog: Dog? = null, var cats: RealmList<Cat> = RealmList(), ) : RealmObject() { } Есть много людей, и у каждого человека есть одна или несколько кошек. […]

RxKotlin – Динамический массив наблюдателей

Я использую RxKotlin вместе с Retrofit 2 Я пытаюсь выяснить, как иметь динамический список наблюдателей за одну операцию. Первый наблюдатель должен запустить операцию, и все дополнительные наблюдатели должны дождаться завершения или неудачной операции По завершении операции мне нужно сделать манипулирование данными (Хранить в кеше / Память), а затем уведомить всех наблюдателей. Вот что я сделал: […]

как перебирать Single <List> и отображать в другой список?

в результате запроса на модификацию я получаю Single<List<Info>> Я должен перебирать каждый элемент и на основе каждого элемента id должен вызывать другой запрос, который также является Одиночным, а затем отображать в DetailInfo и в результате иметь Single<List<DetailInfo>> Я нашел flattenAsObservable и flattenAsFlowable, я не уверен, что это правильный подход, если да, у меня есть другая […]

Как я могу условно добавить асинхронную операцию в середине потока RxJava?

Вот упрощенная версия того, что я пытаюсь сделать (используя Kotlin и RxJava) makeServerCall() .doOnNext { doStuff(it) } //TODO: if it == 0, call asyncOperation() and wait for its callback to fire //before running the rest of the stream. Otherwise immediately run the rest //of the stream .flatMap { observable1(it) observable2(it) Observable.merge( getSpotSearchObservable(observable1), getSpotSearchObservable(observable2) } .subscribeBy(onNext […]

LiveData.addSource onChanged событие, не вызывающее Android

Я работаю с Android Archi + Retrofit + RxAndroid в Котлине. Мне нужно обновить свой объект Data, когда вы получите ответ от сервера. Но liveata.addSource's onChanged не звонит. Я получаю помощь от кода Git: – https://github.com/shahbazahmed1269/AndroidGithubIssues Вот мой код в Котлине: – class LoginRepository : BaseRepository() { fun callLoginApi(data: HashMap<String, String>): LiveData<LoginResponse> { val liveData: […]

RxJava Live Reactive Queue (с выключенным переключателем)

Работа над Android-приложением в котлин. Мне нужно настроить систему, чтобы иметь возможность выполнять работу из живой очереди (и наблюдать за результатами работы в потоке). Но я также должен иметь возможность переключать «обработку очереди» в зависимости от пары внешних факторов (которые также поступают как потоки), таких как networkIsAvailable (Observable<Boolean>) . Я не могу использовать Observable.fromIterable() потому […]

RxAndroid, Как обнаружить, если наблюдаемое закончило излучение

Я пишу следующий фрагмент кода для извлечения списка сохраненной пищи из базы данных firebase, а затем используя этот список, я снова получаю отдельные данные о продуктах из базы данных firebase. После того, как код работает нормально, за исключением того, что я не могу понять, как позволить второй flatMap знать, что эмиссия первой flatMap завершена (весь […]

RxAndroid – использование RxView.touches очищает другие обработчики

Я пытаюсь добавить обработчик привязки к FabricView , но кажется, что я так не умею рисовать. В самом деле, сам FabricView определяет обработчик Touch, но кажется, что моя попытка – использование RxAndroid2 – очищает предопределенный обработчик вместо привязки к нему. Я хотел бы иметь возможность использовать мой обработчик, не очищая существующий. Это часть моего основного […]