問題タブ [rx-kotlin]
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.
rx-java - Rx でサブスクライバーにオブジェクトを繰り返し送信する
Rx のサブスクライバーに同じオブジェクトを繰り返し送信することは可能ですか? たとえば、このコード(Kotlin上):
文字列値「A」をメソッド onNext() に繰り返し送信し、「A111111」を取得しようとしました。Rx ライブラリのメソッド replay() は、新しいサブスクライバーに対して日付の送信を再開することを理解しているためです。オブザーバブルからサークルfor日付が変わらず、メソッドだけが数回呼び出されます
java - RxJava2 のオブザーバブルによって発行された N 個の最後のオブジェクトを取得する
いくつかの数値を発行する Observables があり、単に最後の N 要素を取得したいだけです。
次のコードがあります（RxJavaの単なるラッパーであるRxKotlinを使用しています）：
残念ながら、結果は です[10]。バッファ演算子が返すものをよく見ると、次のようになりました。
最後の「フル」バッファを取得する方法はありますか -> [8, 9, 10]?