Articles of rx java

Неправильное понимание буфера в RxJava

Я пытаюсь познакомиться с RxJava. Вот пример использования, который я пытаюсь достичь: У меня есть кнопка на моем экране, и я пытаюсь собрать количество кранов. Таким образом, если пользователь нажимает кнопку, клик регистрируется и создается журнал. Теперь, если пользователь дважды нажимает кнопку, тогда он регистрирует оба клика, собирает их и выдает 2 вместо 1. По […]

RxJava – загрузка файлов последовательно – испускает следующий элемент, когда onNext вызывает

У меня есть метод, который одновременно загружает несколько файлов в облачное хранилище. Это выглядит примерно так: List<String> files = Arrays.asList("file0", "file1", "file2"); Observable.from(files) .flatMap(file -> uploadFile(file) .flatMap(done -> notifyFinished(file))) .subscribe(this::onNext, this::onError, this::onCompleted); private Observable<Boolean> uploadFile(String file) { Timber.d("Uploading: " + file); return Observable.just(true).delay(6, TimeUnit.SECONDS); } private Observable<Boolean> notifyFinished(String file) { Timber.d("Notify finished: " + file); […]

Retrofit2 и kotlin

Я пытаюсь объединить Kotlin RxJava и retrofit2. @GET("/xxxxxxxxxxxx/{id}.json") fun getHotel(@Part("id") id : String) : Observable<Response<Hotel>> Когда я пытаюсь вызвать этот метод (getHotels ()): var subscription = HotelsFactory.getHotelService((activity.applicationContext as App) .client) .getHotel(arguments.getInt("id").toString()) .subscribeOn(Schedulers.computation()) .observeOn(AndroidSchedulers.mainThread()) .subscribe({response -> showHotels(response)}) {throwable -> throwable.printStackTrace()} mSubscription.add(subscription) Я беру это: Параметры @Part могут использоваться только с многострочной кодировкой.

Зачем нужна функция onBackpressure () здесь для событий click?

Я пытаюсь сделать обработку ошибок для некоторых действий, связанных с нажатием кнопки. Для привязки я использую RxAndroid + RxAndroid. Похоже, что он должен работать с кодом ниже, но он не имеет комментариев с помощью onBackpressure() : CurrentUser signIn() { throw new RuntimeException(); } Integer x = 1; PublishSubject<Throwable> loginingFailedSubject = PublishSubject.create(); @Override public void onStart() […]

Как я могу заставить этот rxjava zip работать параллельно?

У меня есть метод сна для моделирования продолжительного процесса. private void sleep() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } Затем у меня есть метод, возвращающий Observable, содержащий список из двух строк, заданных в параметрах. Он вызывает сон перед возвратом строк назад. private Observable<List<String>> getStrings(final String str1, final String str2) { […]

Использование RxJava для запроса цепочки в одном потоке

Я сохраняю местоположение пользователя в локальной базе данных приложения, а затем отправляю его на сервер. Как только сервер вернется к успеху, я удалю отправленное местоположение. Каждый раз, когда точка была сохранена в базе данных, я вызываю этот метод: public void sendPoint(){ amazonRetrofit.postAmazonPoints(databaseHelper.getPoints()) .map(listIdsSent -> deleteDatabasePoints(listIdsSent)) .doOnCompleted(() -> emitStoreChange(finalEvent)) .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(AndroidSchedulers.from(backgroundLooper)) .subscribe(); } Я запрашиваю базу […]

Не удалось найти класс rx.android.schedulers.AndroidSchedulers

Я использую как rxjava / rxandroid, так и jackson-databind в своем приложении, но кажется, что обе библиотеки не могут работать вместе. Когда я пытаюсь запустить мое приложение, он возвращает следующую ошибку: java.lang.ClassNotFoundException: rx.android.schedulers.AndroidSchedulers Вот мой файл градиента: apply plugin: 'com.android.application' android { compileSdkVersion 23 buildToolsVersion "23.0.2" defaultConfig { applicationId "myapp" minSdkVersion Integer.parseInt(project.ANDROID_MIN_SDK_VERSION) targetSdkVersion 23 versionCode […]

Запись синхронных unittests для Rx v2 Flowable

Я конвертирую свой проект из Rx v1 в Rx v2, и сейчас я в процессе изменения некоторых из v1 Observable s для v2 Flowable s. (Его в Android-проекте с unittests, написанным в Groovy с помощью Spock) Обычно я просто переопределял Планировщиков, используя крючок. Я все еще могу сделать это в v2, зарегистрировав обработчики планировщика. Это […]

Выполнение последовательных вызовов api с помощью Дооснащения и возвращение наблюдаемых

У меня есть служба переоснащения, которая содержит следующий интерфейс public interface ApiService { @GET("/users/me") Observable<Account> authenticateUser(@Header("Authorization") String auth); @GET("/membership/{userId}") SubscriptionStatus getSubscriptionStatus(@Path("userId") String userId); } Я хотел бы определить метод, чтобы сделать api-вызов, чтобы получить Учетную запись, которая содержит userId, а затем использовать этот идентификатор, чтобы сделать второй вызов API, чтобы получить статус подписки на пользователей. […]

Неоднократно совершать вызов API с помощью дооснащения и rxjava

У меня есть дооснащение: @GET("something/") Observable<Something> getSomething(); Подписка на него дает ответ. getSomething().subscribe(new Subscriber<Something>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Something something) { //update database of something } }); Как я могу сделать этот вызов каждые 60 секунд, чтобы я мог обновить базу данных […]

Intereting Posts
Android textview не поддерживает разрыв строки Как записать видео с помощью предварительного просмотра камеры в TextureView Список всех лидеров в сервисах игровых игр Google Какой контекст получает BroadcastReceivers при прослушивании BOOT_COMPLETED? Android Studio 0.8.1 Manifest Merger $ {applicationId} недоступен Можно ли получать уведомление (например, по электронной почте), когда Консоль разработчика Google Play получает аварийный сигнал или ANR? Выполняются ли onPreExecute () и onPostExecute () в потоке пользовательского интерфейса или в потоке, из которого запускается AsyncTask? Android AutoCompleteTextView с данными из веб-службы, проблемы с отображением списка предложений Получать широковещательное сообщение на Android Общие элементы, анимация между фрагментами Android: как заставить GridView ширину wrap_content? Android: как проверить, видима ли View внутри ScrollView? WearableListView setEnableGestureNavigation недоступен Андроида студия 1.2 град очень медленная Тревога очищается при перезагрузке в надводном