rx-scala

1熱度

3回答

我在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熱度

2回答

如何創建兩個排序的observables之間的差異observable？

假設我有兩個有序的雙打的可觀察物。我想把它們之間的區別看作是可觀察的。例如： 1 2 4 left: ──o───────o───────────o────/ 1 3 4 5 right: ──o────o──o───o───/ l2 r3 r5 output: ──────────o───────────o────o─/ 當務之急實現很

0熱度

2回答

如何緩存RxJava/RxScala中的observable

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

1熱度

1回答

RxScala ConnectableObservable.doOnSubscribe永遠不會被調用？

val observable = Observable(...) .publish val subscription = observable.connect observable.doOnsubscribe(() => doSomething) .subscribe() doSomething永遠不會被調用。 RxJava完全相同的代碼正常工作。看來不管是什麼原因，

0熱度

2回答

RxScala「zip」多個觀察對象

在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)) 「拉鍊」可

0熱度

1回答

在RxJava/RxScala中組合groupBy和flatMap（maxConcurrent，...）

我有傳入的處理請求，其中我希望由於耗盡共享資源而不希望進行太多處理。我還希望共享一些獨特的關鍵要求不能同時執行： def process(request: Request): Observable[Answer] = ??? requestsStream .groupBy(request => request.key) .flatMap(maxConcurrentProce

2熱度

1回答

Scalaz vs ReactiveX

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

0熱度

1回答

阿卡流 - 結合最新的操作

我想結合最新的阿卡流，如here所述。我不知道該怎麼做 - 請幫助！謝謝，瑞恩。