問題タブ [rx-scala]

このコードが印刷されると思っていたでしょう

ただし、最初の「購読済み」は出力されません。

次のようなObservableの配列からを作成したかったのです。Observable

Observableこのプログラムは、いくつかのオーバーロードされたメソッドがすべて呼び出されているため、コンパイルされませんmerge。

次に、別の Java クラスを使用してオーバーロードを削除したいと考えました。

Scala コードは次のようになりました (関連する部分のみをここに示します)。

このプログラムはまだコンパイルされません:

3 つの質問があります。

1. merge最初のケースのように純粋な Scala でメソッドを呼び出す方法は?
2. 2 番目のプログラムがコンパイルされないのはなぜですか?
3. Scalamergeで上記のクラスのメソッドを呼び出す方法は?RxUtils

観測可能なストリームを単独でスライスしようとしています。例:

出力は次のとおりです。

sourceboundariesに到達する前に、おそらくオンラインで反復されるresultため、境界と結果のバッファーのみを作成しますが、埋めるものは何もありません。

これに対する私のアプローチはpublish/を使用していconnectます:

これにより、問題なく出力が生成されます。

今、私connectは外の世界から隠す必要があり、connectそれresultがサブスクライブされたときに（クラス内でこれを行っており、公開したくありません）。何かのようなもの：

しかし今、doOnSubscribeアクションは決して呼び出されないので、公開されたものsourceは決して接続されません...

どうしたの？

次の単一サブスクライバーを使用するにはどうすればよいですかReplaySubject。

1. onNext()誰かがサブスクライブするまで、受信したすべてのイベントをバッファリングします。
2. 誰かがサブスクライブすると、バッファリングされたすべてのイベントがサブスクライバに転送され、ReplaySubject(パフォーマンス上の理由から) バッファから消去され、後続のイベントはサブスクライバにのみ転送されます (バッファリングは行われません)。
3. 複数のオブザーバーがサブスクライブしている場合、例外がスローされます。
4. サブジェクトに与えられたすべてのバッファリングされたイベントは、各イベントが生成された時間に基づいて順序付けられ、サブスクリプション中にその順序でサブスクライバーに転送されますか?

また、これは意味がありますか？ファイルシステムなどからイベントを転送する場合など、このテーマには良いユースケースがあると思います...

観測可能なものがある場合:

新しいオブザーバブルを構築する方法:

短い質問かもしれませんが、達成する方法が本当にわかりません。ありがとうございます

ありがとう、私は方法を見つけて、変数の削除を検討しています

私は var がまったく好きではありませんでした。

最後 に、私は光の道を手に入れました.希望は他の人を助けることができます.

他の回答もとても参考になりました〜

Ints のソース Observable があるとします。

ソースで最初に表示された値との差が 10 より大きい値を生成する、別の Observable を作成したいと思います。

ここでは、ソースObservableの最初の値を保持するためにvar startを使用しました。

このコードを単純化する方法はありますか? 変数に値を代入するこのアプローチは好きではありません

ObservableScala Swing のテキスト フィールドからを作成する RxScala コードを作成する必要があります。Github を見た後、私はこのコードを書きました。

Wherefield.textは、そのフィールドのテキストの現在の状態を示します。

ただし、この行はわかりません：

これは何にSubscription役立ちますか？パラメーターを取らないので、このオブザーバブルを参照していないため、作成したオブザーバブルからサブスクライブを解除するために使用できないと想定しています。

では、何がSubscription()良いのでしょうか？

パラメータを取らないのはなぜですか？