rx-java2
Я пытаюсь реализовать RXJava2 Observable<String> от BufferedReader. Пока все хорошо: public class Launcher { public static void main(String[] args) throws Exception { Process process = Runtime.getRuntime().exec("ls /tmp"); BufferedReader reader = new BufferedReader (new InputStrea...
Поиск занимает центральное место в моем приложении, и мне нужно, чтобы он хорошо работал. Прямо сейчас у меня есть SearchView. Мне нужно отобразить результаты в строке, поэтому я использую этот код. searchView.setOnQueryTextListener(new SearchView.OnQueryTextListener() { @Override public ...
У меня есть следующий код: Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(@NonNull final ObservableEmitter<String> s) throws Exception { Thread thread = new Thread(new Runnable() { @Override ...
У меня есть проблема с написанием.наблюдаемые молнии в Котлин, используя Android Studio интегрированная среда разработки 3.0. Вот мой код: internal var updateStringEventsSubject = PublishSubject.create<String>() internal var updateIntEventsSubject = PublishSubject.create<Int>() internal var tr...
Я пытаюсь исправить проблему, когда Retrofit 2 возвращает null в ответ. Интересно, что в эмуляторе все работает нормально, данные принимаются и отображаются,но когда я строю APK, то же самое происходит с NullPointerException. Я прокомментировал строку, где это происходит. Мое телосложение.зависимости gradle:...
У меня есть API, который возвращает только коды ошибок / успехов,без тела. С RxJava1 я бы использовал Observable<Void> в качестве возвращаемого значения для этого вызова. Что я могу использовать для RxJava2? Подсказка на Wiki для RxJava2 (link) не полезна, так как я не могу изменить, как работает API....
Я только что смотрел конференцию Джейка Уортона. состояние управления состоянием с помощью RxJava . Он предлагает преобразовать события из представления в действие следующим образом: Observable<Event> events = RxView.clicks(view).map(__ -> new Event()); ObservableTransformer<Event, Action> ...
Я сталкиваюсь с проблемой, когда мой observable подписывается на поток ввода-вывода и наблюдается в главном потоке android (UI), но оператор doFinally выполняется в потоке ввода-вывода, и он должен быть запущен в потоке пользовательского интерфейса. Usecase почти точно такой же, как этотсредний артикль . ...
Я не получаю причину использовать RxJava в Android и LiveData от Android Architectural Components.It было бы очень полезно, если бы usecases и различия между ними объяснялись вместе с примером примера в виде кода, который объясняет различия между ними....
может ли кто-нибудь объяснить разницу между Observable, Completable и Single в RxJava с четкими примерами? в каком сценарии мы используем один над другими?...