rx-scala で(インターフェイスなしで)Observableエミュレートする方法はありますか? つまり、複数のサブスクリプションを持つことができるように、メモリを使用して Observable にし、新しいサブスクリプションごとに、最後に発行された値を生成しますか?BehaviorSubjectObserver
Observable.publish()半分の仕事をしますが、最後の値を発行しません。Observable.cache.publish()一方、すべての値を再生します-無限のストリームを処理するために、最後に発行された値のみを再生するようなものが必要です。
Rx-Java ソリューションも受け入れられますが、ネイティブの Scala 形式が優先されます!