rx-java

0热度

1回答

此代码的工作 Observable.range(0, 9) .subscribe(new Action1<Integer>() { public void call(Integer item) { LOG.debug("item:{}", item); } }); 越来越：DEBUG：net.test.rx2.App - 项目：0到9，但下面一

0热度

2回答

实现循环作业重复不超过每秒

假设我们再次有这样的事情： while (true) { val job = Future { doSomething(); 1 } val timeout = Future { Thread.sleep(1000); 2 } val both = for (j <- job; t <- timeout) { println("Done") }

1热度

2回答

RxJava：插入分隔符对象

我想插入分隔符对象到集合中。 Observable<String> observable = Observable.from(new String[] { "a", "b", "c" }); Iterable<String> dividedList = observable.flatMapIterable(new Func1<String, Iterable<String>>() {

0热度

1回答

Couchbase SDK 2：批量读取操作，如何将故障转移到复制品

我们是在重构一个基准测试工具，从Couchbase客户端2迁移到新CouchBase SDK的过程2. 旧版本，下面的“批量get”逻辑以检索键在散装，如果失败从主读取，有一个故障转移从“复制品” 遗留码如下： List<Map.Entry<String, OperationFuture<CASValue<JsonNode>>>> futures = new java.util.ArrayList

-1热度

2回答

RxJava做了一件事情，一旦3个不同的事件发生了

我试图通过实现东西流入我的脑袋，绕过RxJava我的头。我有以下努力：有3个按键，分别emmiting不同的事件（姑且称之为A，B和C）的用户应该执行，一旦接收到所有3个事件的一些动作（无关于它们之间的顺序或延迟）。要做什么<>

0热度

1回答

正确的方式重试延迟Couchbase getAndLock如果锁已被占用？

我正在使用新的Couchbase Java Client API 2.1.1，因此JavaRx访问我的Couchbase集群。在已锁定的文档上使用异步getAndLock时，getAndLock将失败，并显示TemporaryLockFailureException。在另一个SO问题（rxjava: Can I use retry() but with delay?）中，我发现了如何延迟重试。

0热度

1回答

RxJava的Android不工作，无法编译代码

我想学习RXjava为Android，所以我也做了以下内容： 1）我已经下载rxandroid-0.24.jar的jar文件， rxandroid-框架-0.24.jar 2）添加的文件在Android Studio中，以libs文件夹 3）添加LIB依赖到Android工作室，请检查下面截图： 4）尝试了我和它似乎在我的片段代码不会看到rxandroid，请检查下面的代码： import rx

4热度

2回答

重复使用者

在RxJava我有一个Subscriber对象，我订购Observable。稍后（在调用onComplete()后的一段时间），我创建了一个新的Observable并订阅了与之前使用的相同的Subscriber实例。但是，这似乎不起作用。用户不可重复使用？例子： class Loader extends Subscriber<T> { public void load(){

1热度

1回答

嵌套压缩的造成的可观回报价值错配

我是很新，反应式编程，并有这样的方法，它不会编译，我无法得到它的权利， public Observable<Data> findData(long templateId) { .. .. return Observable.zip(templateObs, dataObs, (templateObj, dataObj) -> { try {

14热度

3回答

如何在RxJava的动态列表中创建观察者？

我需要在不断变化的数组上创建一个Observer（添加元素）。我正在使用Obserable.from（Iterable），但它似乎创建了ArrayList上的Observable，因为它是在创建时刻。我需要通知观察者，并在每次ArrayList获取新元素时执行Action。