問題タブ [rx-java]
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.
javafx - Elm の高レベルの抽象化を維持しながら、マリオの例を Elm から純粋な JavaFX または JavaFX+RxJava に変換することは可能ですか?
Elm でのリアクティブ プログラミングに関する興味深いプレゼンテーションを最近見ました。
これは、マリオ ゲームを実装するために使用される言語構造 (表示されているプレゼンテーションと下の図でも) が、純粋な JavaFX または RxJava と組み合わせた JavaFX のいずれかで、同様の高レベル言語構造にマッピングできるかどうか疑問に思いました。
言い換えれば、Elm に実装されたマリオ ゲームを JavaFX 単独または JavaFX+RxJava で同じ概念的抽象化 (つまり、時間依存の値) を使用して表現することは可能でしょうか?
したがって、経験豊富な 1) JavaFX プログラマーまたは経験豊富な 2) JavaFX+RxJava+Functional プログラマーがマリオ ゲームを Elm から 1) JavaFX または 2) JavaFX+RxJava に移植したい場合、どのプログラマーが同様の高機能を使用してこのタスクを達成できますか? - Elm で使用されていたようなレベルの抽象化?
私が JavaFX で考えている抽象化はバインディングであり、JavaFX+RxJava ではバインディング + オブザーバブル / サブジェクト / サブスクリプションです。
java - RxJavaでmapとflatMapをいつ使用しますか?
RxJavamapでvsflatMapをいつ使用しますか?
たとえば、JSON を含むファイルを JSON を含む文字列にマップするとします。
を使用して、何とかmap対処する必要があります。Exceptionしかし、どのように?:
を使用するflatMapと、はるかに冗長になりますが、問題を のチェーンに転送し、Observables別の場所を選択して再試行した場合にエラーを処理できます。
のシンプルさが気に入っていますが、 (冗長さではなく)mapのエラー処理が気に入っています。flatmapこれに関するベストプラクティスは見たことがなく、実際にどのように使用されているのか興味があります.
groovy - container.deployVerticle を介してデプロイされたバーティクルで実行すると、Observable.create が groovy.lang.MissingMethodException になる
Groovy verticle (Bar.start) の例外 groovy.lang.MissingMethodException: メソッドの署名がありません: static rx.Observable.create() が適用されます
クラスローダーの問題？わからない。 Vertx のドキュメントでは、container.deployVerticle バーティクルが親クラス ローダーを使用することが示唆されています。
メイヴン:
Vert.x バージョン: 2.1M5
ありがとう
scala - RX Observable を Play Enumerator に変換する方法
ネイティブの Enumerator コンストラクトを使用して Play で websocket を正常にセットアップし、文字列を返すコードを呼び出しました。
Now I want my operation function to return an rx.lang.scala.Observable[String] instead of a String, and I want to output any String as soon as it enters. How can I map this Observable to a play.api.libs.iteratee.Enumerator?
rx-java - rx-java バッファがアイテムを失っている
2 回サブスクライブする PublishSubject があります。最初のサブスクライバーは処理されたアイテムの数をカウントするだけで、この値は常にオブザーバーを介して送信したものと一致します。ただし、他のサブスクライバーはバッファーを使用しており、私 (75%) はオブザーバーを通過したすべてのアイテムを受信しないことがよくあります。バッファを間違って使用していますか? すべてのアイテムが処理されることを確認するために、オブザーバーへの送信を停止した後、タイムスパンよりも長く待機しています。
java - RxJava と Java 8 並列処理ストリーム
それらの間のすべての類似点と相違点は何ですか。Java Parallel Stream には RXJava で利用可能な要素がいくつかあるようです。そうですか?
rx-java - 0.18 では、バックグラウンド タスクはスケジューラでどのように実行されますか?
ここで何かが欠けているように感じますが、以前は次のようにしていました。
サブスクリプション解除を管理せずに、スケジューラを使用してバックグラウンド タスクを実行することはもうできないようです ( https://github.com/Netflix/RxJava/wiki/Schedulerおよびhttps://github.com/Netflix/ RxJava/blob/master/rxjava-core/src/main/java/rx/Scheduler.java )。
0.18 で doWhatever を簡単に実行できるパターンはありますか?
あなたができるようです：
しかし、これはより多くの作業のように思えます (特に android.mainThread スケジューラの場合)。
ここで何を見逃したのですか？