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所述。我不知道该怎么做 - 请帮助！谢谢，瑞恩。