問題タブ [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.
event-handling - Vert.x - RxJava - zip オブザーバブル
Vert.x と RxJava を使用してオブザーバブルに圧縮しようとしています。何かを誤解しているのか、それとも単なるバグなのかわかりません。これがコードです。
受信したメッセージからの情報を使用して HTTP 要求を作成し、HTTP 応答からの情報を使用してメッセージに返信するために、イベント バスと HTTP 応答の両方のオブザーバブルを圧縮したいと考えています。
送信先のメッセージに対する応答がありません。
前もって感謝します！
java - PublishSubject と BehaviorSubject のサブスクライブを解除するにはどうすればよいですか?
パッケージの下には、次のsubjectsようなクラスがあり、使用可能なサンプルとして説明できると思いPublishSubjectます。BehaviorSubjectObservables
これらのサブスクライブを解除するにはどうすればよいですか? メソッドはなくunsubscribe、呼び出しonCompletedは Observable を完全に終了しますか?
scala - RX-Scala で接続可能な Observable を使用して BehaviorSubject をエミュレートする方法
rx-scala で(インターフェイスなしで)Observableエミュレートする方法はありますか? つまり、複数のサブスクリプションを持つことができるように、メモリを使用して Observable にし、新しいサブスクリプションごとに、最後に発行された値を生成しますか?BehaviorSubjectObserver
Observable.publish()半分の仕事をしますが、最後の値を発行しません。Observable.cache.publish()一方、すべての値を再生します-無限のストリームを処理するために、最後に発行された値のみを再生するようなものが必要です。
Rx-Java ソリューションも受け入れられますが、ネイティブの Scala 形式が優先されます!
android - いつRxJava Observableを使用する必要があり、いつAndroidで単純なコールバックを使用する必要がありますか?
アプリのネットワーキングに取り組んでいます。そこで、Square のRetrofitを試してみることにしました。彼らはシンプルをサポートしていることがわかりますCallback
そしてRxJavaのObservable
どちらも一見するとよく似ていますが、実装すると面白くなります...
単純なコールバックの実装では、次のようになります。
これは非常に単純で簡単です。そして、Observableすぐに冗長になり、非常に複雑になります。
それだけではありません。あなたはまだ次のようなことをしなければなりません:
ここで何か不足していますか？Observableまたは、これはsを使用するのに間違ったケースですか? Observable単純なコールバックよりも優先する/する必要があるのはいつですか?
アップデート
@Niels が彼の回答または Jake Wharton のサンプル プロジェクトU2020で示したように、レトロフィットの使用は上記の例よりもはるかに簡単です。しかし、基本的に質問は同じままです - いつどちらの方法を使用する必要がありますか?
scala - 複数の Future Completion に応じて Scala で処理をビルドする方法
私は Scala を初めて使用し、Scala API の完全にノンブロッキングな性質を使用することを学び始めたばかりです。
2 つのタスクが終了した後に関数を実行する必要があります。
これを行うためのより簡単な方法はありますか？