如何测试RxJava Flat Map内部的功能？
我在演示者中有以下方法。 public void addNote(int customerId, String body) { disposables = RxUtil.initDisposables(disposables); if (TextUtils.isEmpty(body)) { view.showNoteTextEmpty();
..
rx-android相关内容
如何在计数时限制重试
我在retryWhen中使用了PublishSubject，以允许用户重试该操作，类似于this answer。一切正常，但有一个问题-在用户点击重试3次后，我应该不再允许重试，并应该中止操作。有没有办法将重试次数限制在3次以内？ 我已尝试PublishSubject.Take(3)运算符，但不起作用。 推荐答案 运算符(如retryWhen)具有次要流，其结果会影响主要流。因此，流操
..
如何在RxJava中处理可观察对象的map()中的异常
我要这样做： Observable.just(bitmap) .map(new Func1() { @Override public File call(Bitmap photoBitmap) { //File creation thr
..
如何在改版Android中传递请求体中包含空值或空字符串的密钥
我需要传递密钥，即使没有值，因为密钥在服务器端是强制的。但Retrofit在发送请求时正在删除具有空值的密钥。如何使用Retrofit实现向服务器发送不带值的密钥？ 请求正文如下： { "first_name":"testlogin", "last_name":"lastname", "username":"testman",
..
使用 Swagger codegen 生成 RX JAVA + Retrofit sdk
我想使用 swagger codegen 生成 sdk，它可以为我生成带有 Observable 作为回调的 sdk，如下所示: @POST("oauth/令牌") 可观察的令牌响应>getRepository(@Query("grant_type") String grantType); 解决方案 您可以使用以下命令作为示例生成启用 RxJava 的 Java Retrofit
..
RxTextView.textChanges 与 Edittext 上的 setText
RxTextView.textChanges(editText).map(CharSequence::toString).debounce(200, TimeUnit.MILLISECONDS).observeOn(AndroidSchedulers.mainThread()).订阅(输入->；{output =//...对输入做一些事情editText.setText(输出)})); 当我 s
..
Rx Java Android:如何将此回调块转换为观察者
我正在尝试通过 Amazon 的 S3 Android SDK 上传文件.我已经稍微使用过 RX Java，但我不确定如何将此方法转换为返回 Observable 的方法，因为我想将此方法的结果链接到另一个 Observable 调用.我想这让我感到困惑，因为这不会立即返回，并且在 OnError 或 OnState 更改之前无法返回.我如何以 RX 方式处理这些情况? public void
..
何时在 Android 中使用 RxJava，何时使用 Android 架构组件中的 LiveData?
我没有得到在 Android 中使用 RxJava 和在 Android 架构组件中使用 LiveData 的理由.如果用例和两者之间的差异以及以代码形式解释之间差异的示例示例一起解释，那将非常有帮助两者兼而有之. 解决方案 Android LiveData 是原始观察者模式的变体，增加了活动/非活动转换.因此，它的范围非常有限. 使用 Android LiveData 中描述的示例
..
使用 RXJava2/RXAndroid 2 和 Retrofit 进行轮询
我想实现一个轮询服务，它每 nDelay 秒调用一个 REST Api，并在数据发生更改时通知所有订阅者.现在我的代码有一个小问题，因为它总是向我的消费者返回一个值，即使数据没有改变. private Observable>pollingLightsObservable = null;公共 Observable>getPollingLightsObservable() {如果(pollingLi
..
rxJava，定期刷新api数据
我使用以下 observable 来调用改造 api，然后将响应保存到缓存文件中: @Override public ObservablestoryEntityList(最终的 int 页面){返回 this.restApi.storyCollection(id, page).doOnNext(saveStoryCollectionToCacheAction).onErrorResumeNext
..
为什么 debounce() 和 toList() 在 RxAndroid 中不起作用?
当我使用 debounce() 时，然后从后端获取数据和数据我想转换为另一个数据并最后使用 toList().当我使用 toList() 时，什么都没有发生，没有任何日志不在订阅和错误中，没有 toList() 它可以工作并且 subscribe()方法输入尽可能多的书籍列表，我测试了代码的第二部分，没有 debounce() 只是 getItems() 并使用 toList() 它有效.下面是我
..
RxAndroid 下载多个文件，最多 3 个并发线程
我有 api 可以从服务器下载单个 mp3 文件，使用 RxJava 如下所示. Observableobservable = audioService.getFile(fileNameWithExtension);observable.subscribeOn(Schedulers.newThread()).observeOn(Schedulers.newThread()).subscribe(
..
如何在 RxAndroid 中使用工作线程
我正在尝试使用 RxAndroid，如下面发布的代码所示.首先，我知道要使用 .delay() 我必须通过“Schedulers.io"让它在工作线程上工作，但 Schedulers 类不提供或没有“.io"线程.如何使用它 库 编译'io.reactivex.rxjava2:rxjava:2.0.1'编译'io.reactivex.rxjava2:rxandroid:2.0.1' 代码
..
使用 RxJava 调用四个 api 的组合
我是 RxJava 的新手 Restapi.class /************/@GET("应用程序/仪表板")ObservablegetCategories(@HeaderMap Map headers);@GET("应用程序/钱包/余额")ObservablegetWalletBalance(@HeaderMap Map headers);@GET("
..
观察者类必须声明为抽象或实现抽象方法
我想在我的项目中使用 RxAndroid 和 RxJava.但是如下面的代码所示，在 getAnimalsObserver() 方法中，下面一行: 返回新的观察者 下划线用红线表示://类必须声明为抽象或实现抽象方法请让我知道如何修复该错误. 代码:进口 rx.Observable;导入 rx.Observer;导入 rx.android.schedulers.AndroidSchedu
..
使用 Java 中的 Reactive Extensions 对对象集合进行排序?
如何使用 rxjava 根据对象的一个或多个字段对对象集合进行排序? 公共类汽车{公共字符串模型；public int numberOfWheels;公共字符串颜色；public int yearOfProduction;}列表汽车 = 新的 ArrayList();汽车.添加(...)；汽车.添加(...)；Observable>getCars() { Observab
..
如何使用 RxJava 绑定单选按钮
我正在关注 Qiitanium 应用程序(请参阅链接中突出显示的行)，但我无法弄清楚如何绑定 RadioButtons 假设我有一个以 R.id.rgMyButtons 作为 Id 的 RadioGroup，它包含 3 个 RadioButtons“Dead"、“Alive"、“Body Missing"，ID 为 R.id.rbDead、R.id.rbAlive、R.id.rb 缺失
..
混合搭配 RxJava 订阅线程
是否可以在 RxJava 中混合和匹配调度程序线程.基本上我想在 Android 上做类似下面的事情. uiObservable.switchMap(o -> return anotherUIObservable).subscribeOn(AndroidSchedulers.mainThread()).switchMap(o -> return networkObservable).subscr
..
在Android中使用glide和Rxjava从url与其他Api调用并行获取位图
我通过以下方式并行调用两个 API. Single.zip(API1.subscribeOn(Schedulers.io()),API2.subscribeOn(Schedulers.io()), Bifunction())).subscribe(); 我想从 URL 加载位图并将位图发回.像这样 Single.zip(API1.subscribeOn(Schedulers.io()),AP
..
如何根据属性以不同的方式继续 Rx 链?
我有一种基于 Flowable 数据值的方法，我需要以不同的方式继续 RX 链.我的意思是，如果数据对象的 isOnline 属性为真，那么我需要调用 scan(initial,selector) 但如果它为 false 那么我需要调用 scan(selector) @NotNull公共 Flowable初始调用(@NotNull Flowable信息，数据初始){返回信息.地图()
..