Articles of rx java

Как отменить запрос с помощью retofit2 и RxAndroid

Я использую Retrofit 2.0 и Rx-android для загрузки своих API. Я следую разделу RxJava Integration with CallAdapter на этом сайте, и он отлично работает. Но я не знаю, как отменить запрос на загрузку с наблюдаемым объектом. Пожалуйста, помогите мне дать мне идею.

Android RxJava присоединился к спискам

Попытка понять все, что RxJava. Я делал следующий пример: private Observable<List<String>> query1() { List<String> urls = new ArrayList<>(); urls.add("1"); urls.add("2"); urls.add("3"); urls.add("4"); return Observable.just(urls); } private Observable<List<String>> query2() { List<String> urls = new ArrayList<>(); urls.add("A"); urls.add("B"); urls.add("C"); urls.add("D"); return Observable.just(urls); } А затем попытался присоединиться к двум спискам: Observable.zip( query1(), query2(), new Func2<List<String>, List<String>, Observable<String>>() […]

Цеповые запросы в Retrofit + RxJava

У меня есть 2 API, которые я хочу сделать в последовательности и хранить их в SQLite. Сначала я хочу сделать запрос к API A и сохранить его данные в таблице SQL a . Затем выполните запрос API B и сохраните его данные в таблице b и некоторые данные в таблице a_b . Данные, хранящиеся в […]

Android Studio добавляет библиотеку rxjava

Рассмотрим следующую структуру проекта: MainProject -.idea -.grandle -src -SubProject –libs //I created this folder manually —rxjava-core-0.16.0-sources.jar –src —main //+ all the sources –build.grandle –SubProject.iml -build.grandle -//other files Я загрузил .jar из http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20a%3A%22rxjava-core%22 (sources.jar ) – но я также пробовал другие Затем я создал папку lib в SubProject, а затем поместил в нее .jar. В Android […]

События текстового просмотра RxAndroid, вызываемые автоматически перед событиями изменения текста

Я использовал rxandroid для операции debounce в поиске edittext я использовал private void setUpText() { _mSubscription = RxTextView.textChangeEvents(searchStation)// .debounce(500, TimeUnit.MILLISECONDS)// default Scheduler is Computation .observeOn(AndroidSchedulers.mainThread())// .subscribe(getOps().getdata()); } И наблюдателем, как public Observer<TextViewTextChangeEvent> getdata() { return new Observer<TextViewTextChangeEvent>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { e.printStackTrace(); } @Override public void […]

RxJava и Retrofit2: NetworkOnMainThreadException

Я понимаю, что я использую subscribeOn () / observOn () на MainThread. Каков набор параметров, которые я могу передать в subscribeOn ()? Каков набор параметров, которые я могу передать в функцию наблюдения ()? 12-17 21:36:09.154 20550-20550/rx.test D/MainActivity2: [onCreate] 12-17 21:36:09.231 20550-20550/rx.test D/MainActivity2: starting up observable… 12-17 21:36:09.256 20550-20550/rx.test D/MainActivity2: [onError] 12-17 21:36:09.256 20550-20550/rx.test W/System.err: android.os.NetworkOnMainThreadException […]

RxJava / Retrofit – Как заставить пользователей использовать определенный подкласс Subscriber?

Перед использованием rx.Observable я использовал специальный обратный вызов с модификацией, поэтому я могу добавить определенную логику для обработки ответа / ошибки и не делать этого внутри обратного вызова для каждого запроса в качестве шаблона. Я заставляю пользователей использовать пользовательский обратный вызов, помещая его в подпись метода следующим образом: @GET("/user_endpoint/") void getUser(CustomCallback<User> callback); @GET("/profile_endpoint/") void getProfile(CustomCallback<Profile> […]

Как разрешать дубликаты файлов, скопированных в APK META-INF / rxjava.properties

Я использую rxjava и rxvolley в моем приложении для Android. Когда я пытаюсь запустить его, я получаю эту ошибку Execution failed for task ':testapp:transformResourcesWithMergeJavaResForDebug'. > com.android.build.api.transform.TransformException: com.android.builder.packaging.DuplicateFileException: Duplicate files copied in APK META-INF/rxjava.properties File1: C:\Users\Daniel\.gradle\caches\modules-2\files-2.1\io.reactivex\rxjava\1.1.0\748f0546d5c3c27f1aef07270ffea0c45f0c42a4\rxjava-1.1.0.jar File2: C:\Users\Daniel\.gradle\caches\modules-2\files-2.1\io.reactivex.rxjava2\rxjava\2.0.3\d2f725668bd22e21170381b23f8fbdf72c69d886\rxjava-2.0.3.jar У меня есть файл exclude.gradle, подобный этому android { packagingOptions { exclude 'META-INF/DEPENDENCIES.txt' exclude 'META-INF/NOTICE' exclude 'META-INF/NOTICE.txt' exclude […]

Android: Realm.getInstance (контекст) возвращает уже закрытый экземпляр области

Realm.getInstance(context) редко возвращает уже закрытый экземпляр области. Как это возможно? Я использую Realm с RxJava, за https://realm.io/news/using-realm-with-rxjava/ В частности, этот метод генерирует IllegalStateException: This Realm instance has already been closed, making it unusable. @Override public void call(final Subscriber<? super RealmList<T>> subscriber) { final Realm realm = Realm.getInstance(context); subscriber.add(Subscriptions.create(new Action0() { @Override public void call() { […]

Как обрабатывать различные ошибки в Retrofit Rx onError без уродливого экземпляра

Я хотел бы знать ваши способы обработки различных ошибок (например, исключений HTTP, исключений для подключения к интернету и т. Д.) В retrofit Rx onError без использования instanceof как это предлагается здесь: как обрабатывать сетевые ошибки в Retrofit 2 с помощью RxJava или здесь: Handle Ошибки в Retrofit 2 RX В kotlin я просто сделаю некоторые […]