問題タブ [rx-scala]

次のrxscalaコードが期待どおりに動作しない理由を理解できません:

をグループ化し、projectEvents各projectNameプロジェクトのアイテムを印刷したいと考えています。しかし、このコードを実行すると、次のように表示されます。

######### event in projectプリントはありません。

理由がわかりません。見逃したものはありますか？

1 つのプロジェクトでRxJavaとRxScalaの両方を使用する方法はありますか?

JavaObservable（RxJava ）を使用しているJavaで書かれたモジュールがあります。そして、Java モジュールを使用することになっているが、Scala で書かれている Scala モジュールがあります。

これらを他のものに変換する便利な方法はありますか?

前の値と着信イベントに基づいて新しい値を無限に生成する計算を考えると、それも失敗する可能性があります。これが 2 つObservableの を取得する最良の方法です。

• 変換を成功させるには、無限の可能性があります。
• エラー報告用？

詳細

イベントによって変更される状態を ScalaFX GUI からモデル化し、RXScala を初めて試しています。物事を単純化する：

アイデアはObservable[State]、与えられた初期状態を作成し、イベントに基づいて次の状態に変更することです。簡単です：

ここで実際の問題は、次の状態の計算には I/O が含まれ、失敗する可能性があるため、computeNext は Try[State] を返さなければならないことです。

明らかに、私はもう使用できませscanん。一般的に、私は2つの s を持ちたいですObservable:

Try[State]が失敗した場合、observableState単に何も発行せず、エラーも報告しないというルールを使用します。次の状態は、最後に成功した計算に基づいています。

この状況を解決する最もエレガントな方法はどれですか?

Observableのリストの結果からリアルタイムでを生成したいFutures。

最も単純なケースでは、 で実行している先物のリストがあり、Future.sequenceで進行状況を監視しているとObservableします。私は基本的に次のようにしています：

これは私のテスト環境では問題なく動作します。onNextしかし、少なくとも重複する呼び出しがないことに注意せずに、異なるスレッドから呼び出すべきではないことを読んだところです。これを修正するための推奨される方法は何ですか? の多くの実際の使用でObservablesは、このような非同期コードから呼び出す必要onNextがあるようですが、ドキュメントで同様の例を見つけることができません。

ループ内で発生したマルチObserverサブスクライブを使用しようとしましたが、すべてのオブザーバーでは機能しないようです。ObservableonNext

最初のオブザーバーのみの応答

2 番目のサブスクライブを受信できないのはなぜですか? ありがとう

私は RxScala/Java を使用して Observable を構築し、ループでソケット接続を発行します。結果は、すべての接続がイベントとして生成されます。このように、

その後、接続が読み取りを開始できるようになります。scoket接続イベントをサブスクライブし、新しい Observable として作成する必要があります。,return
ConnectedSocketを使用して、Observable を接続とし​​て作成することができます。受信した情報でイベントを発行します。このステートメントを return にしたいです。どのように構築しますか?stratReadingObservable[CompletedProto]Observable[CompletedProto]

詳細情報が必要な場合は、更新します。

私はRxで新鮮です.Observableバッファイベントデータのようです。cold observableまたはそれにより replay、データストリームは、長時間経っても後のオブザーバーに送信されます。しかし、いつガベージされるのでしょうか? また、Rx を使用する場合、メモリをどのように処理する必要がありますか?

私は

エラーを出力する

RxScalaでカスタムスケジューラを使用する方法