問題タブ [rx-scala]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - Scalaz vs ReactiveX
私は Java で ReactiveX 拡張機能を数年間使用してきましたが、現在は scala に移行しており、多くの人が拡張機能 ScalaZ を使用して Scala でより機能的なプログラミングを実行しているのを見てきました。
ScalaZ 拡張機能を使用すること、または単に reactX を Scala に適応させることに何か違いはありますか?
そして、このブログhttps://medium.com/@luijar/the-observable-disguised-as-an-io-monad-c89042aa8f31を読んだ後、オブザーバブルはScalazのようにIOモナドとして機能していました
よろしく。
mongodb - Observable: 放出された項目が X 個未満の場合に切り替える
観測可能なobs1、obs2、obs3、...、のリストがあります
それらのそれぞれは（mongodbデータベースから）いくつかのアイテムを発行できます。私は最初のN個のアイテムだけに興味があります。オブザーバブルのクエリが必要な場合にのみ実行されるようにしたいと考えています。つまり、たとえば obs1 が N を超える値を生成する場合、obs2 の背後にあるクエリは実行されるべきではありません。
concat: Observable(obs1, obs2, obs3, ...).concat を使用すると、すべてのクエリを mongodb で並列に実行できます。
基本的に、obs1.switchIfX(obs2).switchIfX(obs3)..... のような操作を探しています。
X: N 未満のアイテムが現在のオブザーバブルによって放出されます。
この要件を rxscala スタイルで実装する方法はありますか?