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<?>的對象，然後構造你的結果對象並將它發回給調用客戶端。但是關鍵是不要阻止