rx-java

0зной

1ответ

public void getTerms(boolean showDialog) { service.getTermsFromServer().subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new SingleSubscriber<String>() { @Ov

0зной

2ответ

В RxJava, что является тип снижения экспрессии

Рассмотрим следующее: import io.reactivex.Observable; import io.reactivex.observables.GroupedObservable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; public c

0зной

1ответ

неспособны испытать слияния оператора rxjava

Я хотел проверить merge оператора с использованием rxjava 1 с помощью: Observable<Object> o1 = Observable.create((t) -> { t.onNext("1"); try { Thread.sleep(5000); } catch (Ex

1зной

2ответ

базы данных (SQLite) транзакции для последующих операторов с rxJava

Предполагая, что у меня есть некоторый поток элементов: Observable<Item> stream = ... Что я пытаюсь достичь? Поток имеет любое количество операций. Все операции до начала транзакции должны выполнять

1зной

2ответ

RxJava объединить несколько наблюдаемых do sth после всех сделанных

У меня есть метод, который должен перезагрузить БД с помощью нескольких наблюдаемых. В конце концов, он должен вызывать метод setupPlace (selecetedPlace), но только один раз. Каждый наблюдаемый возвра

3зной

2ответ

Iterate list with RxJava/RxAndroid

Я новичок в RxJava/RxAndroid, но я застрял в своем прецеденте. Я пытаюсь перебирать в List<A> преобразовать каждый A в B асинхронно (потому что он должен позвонить в базу данных), и мой Observer долже

0зной

1ответ

RxJava управляется событиями. Должно быть, это не сообщение?

Реактивный манифест четко определяет реактивную систему как управляемые сообщения системы и четко дифференцирует сообщение приводной системы из управляемых событий систем См глоссария http://www.react