rx-java

0热度

1回答

我有一个列表Observables，我目前通过Observable.concatDelayError()订阅。我的要求发生了变化，因此我现在想要有条件地延迟错误。如果一个Observable发出一个错误，我想在这一点上决定是否允许剩下的Observable继续或者序列终止。一个用例是如果错误类型为TimeoutException，那么我会中止其余的Observables;否则，我继续处理其余的

0热度

1回答

当Android设备被锁定时，RxJava间隔和超时会偶尔停止

我的一个应用程序功能旨在在5分钟后超时（以防止用户意外启用它）。活动显示一个倒数计时器，该计时器由Observable.interval()更新，功能超时通过Observable.timeout()执行。偶尔当倒计时正在运行，并且用户锁定设备，将停止发射和timeout()不会抛出它的超时异常。当设备解锁并且活动再次处于前台时，最终timeout将在不确定的时间量之后发出异常。在this

0热度

1回答

Android＆Rx Java 2：当对象发生变化时得到通知

我尝试了谷歌搜索，但结果都是关于rxjava 1和2之间发生了什么变化......不如帮助，哈哈。我是Rx Java的新手，正在努力。我可以很容易地创建一个可观察对象，并且所有订阅者都可以获得正确的调用。我只是有一个问题： Object myObject = something1; 我创建了observable和所有订阅者，他们在onNext（）方法中获取myObject。但是，在某个地方，我

-2热度

1回答

是什么RxJava2CallAdapterFactory.create（）的改造

的作用是什么RxJava2CallAdapterFactory.create（）的作用... Retrofit retrofit = new Retrofit.Builder() .baseUrl("https://api.example.com") .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .build();

0热度

1回答

将Akka Sources转换为RxJava2 Flowable？

我目前使用下面的代码转换的阿卡源（如读取用阿卡的FileIO专注文件接收）到RxJava2可流动： private Flowable<Buffer> akkaConversion(Source<ByteString, NotUsed> data, Flow<ByteString, ByteString, NotUsed> compType) { final Publisher

1热度

2回答

使用响应式编程的Android表单验证

我对RxJava，RxAndroid相当陌生。我有两个editText密码和一个密码确认。基本上我需要检查两个字符串是否匹配。是否可以使用Observables来做到这一点？真的很感谢一个例子，所以我可以把握它。干杯。

0热度

1回答

如何在RxJava2中默默跳过异常？

我有一个这样的数据流： Observable .fromFuture( CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>> listOf(1, 2, 3, 57005, 5) }, Schedulers.computation()

1热度

1回答

如何使用RxJava 1生成Fibonacci序列？

斐波纳契仅仅是一个更普遍问题的简单例子，下一个元素依赖于前一个元素。 https://github.com/ReactiveX/RxJava/wiki/Problem-Solving-Examples-in-RxJava提供了一些不错的方法来做到这一点，但他们仍然有点哈克。 generate()也是推荐的，但在RxJava 1中不可用。有什么可以做到这一点的替代方法？是否有相当于generate

0热度

1回答

使用RxJava2从异步HTTP请求序列创建一个流动背压

我想创建一个Flowable来传输从异步REST API端点接收到的结果，该端点发送每个块的结果（必须发送另一个请求以获取使用前一个响应中的头部的其余结果列表）。它不想使用背压策略，而是只在必要时才发送后续HTTP请求（在Flowable中请求时）。函数Flowable.generate非常接近我想要的，但它似乎只适用于同步调用。有没有类似于这个异步调用的解决方案，或者你有任何建议来做到这一点？

1热度

2回答

RX java/Android如何实现这个烤面包上每次点击使用去抖动运算符

我有这ImageView哪些点击应该显示烤面包，也使图像点击图片查看，所以我决定使用Debounce运算符在Rx 但现在每次点击都不会显示thost。下面是代码 cartSubscriptionDecrement = RxView.clicks(holder.databinding .cartQuantityLayout.ivDecreaseQuantity) .deb