rx-java

9热度

2回答

此代码是否线程安全？ Observable<String> observable = ... // some observable that calls // onNext from a background thread observable .scan(new ArrayList<String>(), (List<String> acc, String

1热度

2回答

如何使用leiningen在clojure中使用rxjava的当前版本

我想使用Clojure中经常在https://github.com/Netflix/RxJava上构建的一些最新功能，但是在让Leiningen参考我构建的本地.jar文件时遇到一些困难。发布Clojars rxjava的最后一个版本是0.9.0，我可以用下面我projects.clj :dependencies [[org.clojure/clojure "1.5.1"] [

11热度

1回答

创建rx后添加元素Observable

如何在创建Observable后添加元素时如何实现场景，完全可以实现？在观察者模式中，我只会触发事件。你有什么想法吗？ import rx.lang.scala._ val target = Observable(1,2,3,4) val subscription1 = target subscribe(println(_)) val subscription2 = target sub

7热度

2回答

Android上的RxJava和随机零星事件

我想使用RxJava，就像我使用Guava的EventBus或Otto一样，但我没有看到如何让它以这种方式运行。这是场景：假设我想在我的Android应用程序中有一个按钮，并且每次按下按钮我都希望RxJava通过我的Observable发出一个事件。在我看来，在获得事件后我必须获得服务reregister，并且该活动也需要创建新的可观察事件。一样，如果我说 Observable.from(x)

1热度

1回答

取消订阅后我的订阅保持运行

我正在尝试学习RxScala。我正在使用Observable.interval(1 second).buffer(10 seconds)并进行订阅以打印值，但无法取消订阅权限。取消订阅订阅后，它会继续运行，但结果为空。我的代码： import scala.language.postfixOps import scala.concurrent.duration.DurationLong imp

3热度

1回答

Observable/toObservable未找到静态函数？

下lighttable使用rxjava（http://netflix.github.io/RxJava/javadoc/）使用Clojure 1.5.1，请考虑以下（使用副作用的，突变（恐怖）外部集电极从单子提取数据！） (ns expt1.core (:import [rx])) (def ^:private collector (atom [])) (defn- collect [ite

8热度

1回答

rxjava和clojure异步之谜：期货承诺和代理人，哦我的

我为这篇文章的长度提前道歉。我花了相当多的时间缩短了时间，而且这个数字尽可能小。我有一个谜，并会感激您的帮助。这个神秘来自我在Clojure写的一个rxjava observer的行为，这个行为来自于在线样本中的几个简单的observable。一个observable同步地发送消息给其观察者的处理程序，并且我所谓的原则性观察者按预期行事。另一个可观察的异步在另一个线程上通过Clojure f

4热度

1回答

如何从客户端角度使用异步方法

因此，我对整个功能反应模式产生了浓厚的兴趣，并试图将这些实践中的一些措施落实到位。但我仍然在努力理解的一件事是如何在前端使用这些异步的服务器端调用。假设您的服务层产生了一个Observable<?>对象，该对象将由您的控制器调用。大。但是现在，你如何处理来自客户端的异步结果呢？通常这是你阻止结果的地方，比如来自Future<?>的对象，然后构造你的结果对象并将它发回给调用客户端。但是关键是不要阻止