rx-scala

0熱度

2回答

在RxScala中如何「拉鍊」超過2個觀察對象？ val ob1: Observable[Int] = Observable.from(Future(10)) val ob2: Observable[Int] = Observable.from(Future(20)) val ob3: Observable[Int] = Observable.from(Future(30)) 「拉鍊」可

2熱度

1回答

Scalaz vs ReactiveX

我已經在Java中使用ReactiveX擴展工作了幾年，但現在我轉向scala，並且我看到很多人使用擴展ScalaZ在Scala中執行更多功能編程。是否有任何差異使用ScalaZ擴展，或者只是適應reactiveX Scala，我所知道的與Scala很好？和閱讀之後這個博客https://medium.com/@luijar/the-observable-disguised-as-an-io-

2熱度

2回答

可觀察的異常處理

我正在學習RxScala並來到這個非常合成的片段。我試圖處理例外的onError塊： def doLongOperation():String = { (1 to 10).foreach { _ => Thread.sleep(100) print(".") } println() if (System.currentTim

2熱度

1回答

可運行的行爲主題？

是否有可能有一種BehaviorSubject暫停和恢復開關？像PausableBehaviorSubject.pause()和PausableBehaviorSubject.resume()？這怎麼可能完成？這個想法是，暫停時，主題不會轉發通過PausableBehaviorSubject.onNext()收到的事件，而是隻存儲最後一個。在恢復時（或者在訂購時，如果不暫停），PausableB

1熱度

1回答

調用（超載）RxJava從斯卡拉

功能，我想從Observable就像這樣的數組創建一個Observable： package rxtest import concurrent._ import concurrent.ExecutionContext.Implicits.global import rx.lang.scala._ import rx.lang.scala.JavaConversions._ impor

1熱度

3回答

將RxJava Observable轉換爲RxScala Observable

我在Scala中編寫了一個小型的JavaFx應用程序，我喜歡使用RxScala和RxJavaFx。用下面的代碼，我收到了RxJavaObservable： JavaFxObservable.fromObservableValue(textfield.textProperty()) 顯然，正如我在斯卡拉寫，我想有一個RxScalaObservable來代替。現在我找到了this post，說我要

0熱度

1回答

基於資源稀缺可觀測到的背壓

在RxJava 1/RxScala中，如何在下列情況下節流/背壓可觀測源？ def fast: Observable[Foo] // Supports backpressure def afterExpensiveOp: Observable[Bar] = fast.flatMap(foo => Observable.from(expensiveOp(foo)) // Signa

1熱度

1回答

在RxScala中管理訂閱的最佳做法是什麼？

我想控制我的訂閱，甚至在例外的存在範圍，而使用VAR我的訂閱在接收/ F＃避免我會做這個 use subscription = Observable.subscribe ... 和訂閱在離開示波器時自動處理。斯卡拉的最佳實踐是什麼？

0熱度

1回答

無法打印分組

後可觀察的項目可以不明白爲什麼預期以下rxscala代碼是不工作： import rx.lang.scala.Observable object MyTest extends App { case class ProjectEvent(projectName: String, description: String) val projectEvents: Observa

0熱度

2回答

如何緩存RxJava/RxScala中的observable

我有一個REST API，它使用基於RxScala的反應式scala驅動程序來調用mongodb。在我的API控制器或服務層，我需要用緩存來避免通話使用hazelcast（或任何其他緩存工具）我所有的服務都是異步，只返回觀察到的，任何想法如何，我可以給的MongoDB用可觀察的方式實現緩存？