rx-android

首页 > TAG信息列表 > rx-android

android-如何在RxJava中链接任务

我正在进行android应用程序注册,在该应用程序中,我需要一个接一个地执行几个任务任务1 任务2任务3 我想将这些任务一个接一个地链接起来,如果一个任务失败,则整个过程应该失败. 我想通过Rxjava解决此问题,谁能告诉我如何使用rxJava实现此问题. (我已经浪费了5个小时,但是在RxJava

如何使用RX Java在EventBus上正确处理onError

我在Android上使用rx java,我的事件总线类如下 public class EventBus { private final Subject<Event, Event> subject = new SerializedSubject<>(PublishSubject.<Event>create()); private Observable<Map<Type, Event>> stickyObservable; public Even

android-RxJava：如何从flatMap运算符中的错误中恢复

我有一个EditText,用户在其中输入搜索查询,当用户键入内容时,我想在服务器上执行即时搜索. 我尝试使用RxJava做到这一点,如下所示： RxTextView.textChanges(editQuery) // I'm using RxBinding for listening to text changes .flatMap(new Func1<CharSequence, Observable<Use

RxJava / Android监视在不同时间触发的多个订阅者的进度

我正在寻找一种方法,希望使用RxJava来保持一致性,以监视可能在不同时间触发的多个订户的进度.我知道如何从一个方法中将所有用户同时触发后将它们合并或合并在一起,但是我不知道在不同时间从不同方法中触发它们时会采用哪种方法. 例如,如果我有2个长时间运行的任务附加到按钮按下上

android-flatMap中的NetworkOnMainThreadException

我是rxjava或rxandroid的新手,我想将AsyncTask和回调地狱更改为Observable和Subscriber.但我对此有疑问.我需要对数据库执行两个请求. 我对第一个请求的答复将是第二个请求的结果.我尝试使用flatMap解决此问题.第一个请求返回值,一切正常,但是下一个请求给了我NetworkOnMainThreadE

android-RxJava2：如何获取工作专用的后台线程

是否可以在专用后台线程上安排工作？我需要确保工作是串行完成的,但也必须在后台完成. 基本上-蹦床和io调度程序是否组合在一起？解决方法:只需使用一个只有一个线程的ThreadPool. RxJava2提供了这样的标准调度程序： Schedulers.single() 或使用Factory方法： Schedulers.from(Executor

android-Kotlin Rx：必需的使用者,找到KFunction

我正在使用Kotlin Retrofit Rx.我想将请求之一提取为函数： fun getDataAsync(onSuccess: Consumer<Data>, onError: Consumer<in Throwable>) { ApiManager.instance.api .getData("some", "parameters", "here") .sub

android-flatMap如何深入工作？

我对flatMap如何控制其“子”线程感兴趣,例如以下代码可以正常工作： private Flowable<PlcDataPackage> createIntervalPlcFlowable() { return Flowable.interval(1, TimeUnit.SECONDS, Schedulers.computation()) .onBackpressureLatest() .paralle

RxJava主题和错误处理

我正在尝试实现类似于事件总线的行为.对于我的要求,似乎可以使用PublishSubject. 主题发出表示某些全局操作结果的项目,这些操作可能成功解决,或者在出现异常的情况下失败.在发生错误的情况下,我无法将onNext()用于成功事件,将onError()与Throwable一起使用,因为一旦调用onError(),

RxJava,获取第一项(如果存在)

我正在尝试使用RxJava从列表中获取第一项.但是,如果项目不存在,我不希望它引发错误.相反,我希望能够通过提供默认项来自己处理. 我在下面创建的代码可以正确地检索列表中的第一项.虽然我不知道如何将.exists()合并到其中. api.getLibraryEntries(username) .observeOn

尽管实现了doOnError,但RxAndroid导致应用崩溃

我有以下代码.基本上,这是尝试将所有数据从特定SQLite表发送到DynamoDB： Observable.create(new Observable.OnSubscribe<Area>() { @Override public void call(Subscriber<? super Area> subscriber) { try { for (Area item : areaDao.listAll()) {

如何使用RxJava重复网络通话

我有一个API,可让我使用如下所示的ID来检索商品： http://myapi.com/api/v1/item/1 最后一个值是项目的ID.很好,很花哨,我可以编写一个Retrofit服务接口,并调用如下所示的项： MyService service = MyService.retrofit.create(MyService.class); service.itemById(1)

android-使用RxJava与取消订阅之间的活动之间可以共享观察

我正在尝试实现在我的应用程序的活动之间共享的计时器Observable.我正在实现一个Dagger单例类的实现,我将其注入到每个不同Activity的每个Presenter中. 我以这种方式创建了一次Observable： Observable.defer(() -> Observable.timer(milliseconds, TimeUnit.MILLISECONDS).map(t ->

android-单击两次后退按钮以退出rxjava的活动

寻找一种微妙的rx方法来退出活动,同时按两次返回按钮. boolean doubleBackToExitPressedOnce = false; @Override public void onBackPressed() { if (doubleBackToExitPressedOnce) { super.onBackPressed(); return; } this.doubleBackToExitPres

java-Retrofit对象返回为null

我已经建立了RetroFitService以返回一些对象.在MainActivity中,我只需单击一下按钮即可调用该服务.我似乎正在获取某种对象,但是我不觉得它实际上是从我指定的REST API返回的.它显示在调试器中,但其属性为null： bFetch.setOnClickListener(v -> { v.startAnimation(AnimationUtils

android-RxJava：知道何时可观察完成,并将布尔可观察的返回给调用方

我是RxJava的新手.我的经验主要来自这些教程： Here和here. 现在,我发现自己处于使用Retrofit2进行API调用的情况,该调用将返回Obesrvable< AccessToken>.客户端将按以下方式调用此服务： public Observable<TokenResult> authenticateWithClientCredentials() { return authS

android-使用rxjava2遍历列表

我有一个自定义对象列表(List< Item> itemsList).这是我的自定义课程： public class Item { private String itemId; private String itemName; } 初始列表只有itemName； itemId将为空.我想遍历列表,为每个项目添加一个itemId,然后使用新列表,我需要对列表中的每个项目进行

android-避免使用RxJava的Thread.sleep

我将observable应用于此方法,但是在调用此方法后,它表示主线程上的工作过多.任何帮助表示赞赏 fun isBatteryHealthGood(): Observable<Boolean> { var count = 0 intent = context.registerReceiver(broadCastReceiver, IntentFilter(Intent.ACTION_BATTERY_CHAN

android-如何使用RxJava将双精度值的嵌套列表转换为Java类？

在我的Android客户端中,我从后端收到此JSON数据： [ [ 1427378400000, 553 ], [ 1427382000000, 553 ] ] 这是实际加载数据的例程.我在这里使用RxAndroid和Retrofit. private void getProductLevels() { Observable<List<Lis

如何使用retofit2和RxAndroid取消请求

我正在使用Retrofit 2.0和Rx-android来加载我的API.我在this site跟随RxJava与CallAdapter集成,它工作正常.但是,我不知道如何使用可观察对象取消加载请求.请帮忙给我一个主意.解决方法:取消RxJava Observable执行的唯一方法 – 取消订阅它. RxJavaCallAdapter将取消委托给okhttp客

android – 如何解决APK META-INF / rxjava.properties中复制的重复文件

我在我的android应用程序上使用rxjava和rxvolley.当我尝试运行它时,我收到此错误 Execution failed for task ':testapp:transformResourcesWithMergeJavaResForDebug'. > com.android.build.api.transform.TransformException: com.android.builder.packaging.DuplicateFileExcep

java – 组合一个Observable列表并等待所有完成

TL; DR 如何将Task.whenAll(List< Task>)转换为RxJava？我现有的代码使用Bolts构建异步任务列表,并等待所有这些任务完成后再执行其他步骤.基本上,它构建了List< Task>并返回单个任务,当列表中的所有任务完成时,根据example on the Bolts site标记为已完成. 我正在寻找用RxJava替换B

android – 使用retrofit和rx java的多个api请求

我是android的新手,我有一个场景,我想从多个api获取数据.假设api_a,api_b,api_c,api_d.这些api彼此独立,但我想在混合Recycler View(水平和垂直)中显示来自这些api的数据.所以我想以这样的方式进行这些api调用,以便我可以一次获取每个api数据,以便我可以在回收器视图中显示. 我已经

android – 了解数据流和多个订阅者(使用改进)

假设我有两个基本上是网络调用的Observables(A& B)(使用Retrofit来提供上下文). 该应用程序的当前流程如下： > A& B大约在同一时间(异步)开始. > B在用户交互时执行0次或更多次鉴于这2个observables / api调用,我有3个不同的场景我想听. >我想在Observable A完成时立即知道>我想在O

RxJava流程：条件运算符和错误处理

我是RxJava的新手,并尝试围绕一个更复杂的登录逻辑,包含三个异步方法来处理.对我来说这是“如果我将这个东西转换为RxJava,任何东西(tm)都是可能的”:) 所以我想做的是以下内容： Call A -> (Process A) -> Call B with results of A -> (Process B) -\ \