問題タブ [rx-scala]

タイムアウトによってオブザーバブルの寿命を制限しようとしています:

次の結果を区別したいと思います。

1. Observable はタイムアウトで終了しました。結果は得られませんでした
2. 実行中にスローされた例外
3. 実行は正常に終了し、戻り値

ケース 2 と 3 はパーシャル onNext と onError で問題なく処理できますが、オブザーバブルがタイムアウトで終了したかどうかを検出するにはどうすればよいですか?

もう 1 つ: 私のコードには obeserver.onCompleted() への呼び出しがありますが、ブロック onComplete に入ったことがありません。なんで？

私のリアクティブ プログラムを rxscala でテストするには、次のようなものを作成する必要がありますObservable。

どれの

1. 発行番号1
2. それから待つ1s
3. 発行番号4
4. それから待つ3s
5. 発行番号2
6. それから待つ2s

私は醜い解決策を持っていますThreadとReplaySubject：

より良い解決策はありますか？

簡単なrxscalaコード:

実行すると、例外がスローされます。

どこが間違っていますか？

を実行する方法filter、mapおよび複数のスレッドflatMapを使用する場合:Observable

目標は、複数のスレッドを使用してフィルター操作と変換操作を同時に実行することです。

eaを処理したいです。クエリ フェッチ (クエリごとに複数のフェッチが行われる可能性があります) を非同期的に行います。これを行うために、処理関数 ( a を返すFuture) をクエリ メソッドに渡して、それを呼び出します。フェッチ。クエリの結果サイズは事前にわかりません。フェッチの最大サイズしか知りません。したがって、私のクエリは(事前にサイズを知る必要がObservableある for ex. とは対照的に) を返します。List唯一の問題は、Observable createorを使用すると、次の onNext を呼び出す前にapply、 my が完了するまで内部的にブロックされることです。事実上、先物から得たいと思っていたパフォーマンスの向上が失われます。Futureファクトリ メソッドはObservable fromブロックしませんが、Iterable. 私はそれをミュータブルに渡すことができますIterable新しいフェッチが入ると成長します。誰かがより参照透過的なsol'nを持っていますか? コードは次のとおりです。

rxscala を使用すると、次のようにオブザーバブルをサブスクライブできます。

側からすべてのオブザーバー (4 つあります) のサブスクライブを解除することは可能streamですか?

私はrxscalaを使用していて、非常に微妙な問題を発見しました.私のコードは次のように単純化されています:

キーポイントは、それ自体!!!(2)の内側にある線です。projects

以下を出力します。

線がないのが難点### 222:！

しかし、collectパーツを変更してケースを追加するとNone:

### 222:期待どおりに行が出力されます。

理由がわかりません。

PS: ここでコードを複製できます: https://github.com/freewind/rxscala-test/blob/master/src/main/scala/myrx/SubtleBug.scala

私は Reactive Extensions にまったく慣れていないので、次のことに興味がありました。

Scala で Rx を使用することにより、API からコンテンツを取得するメソッドを毎秒呼び出せるようにしたいと考えています。

これまで、Interval、Timer などの Rx 内で使用される作成演算子を見てきました。しかし、残念ながら、私は正しい解決策を思い付くことができません。

誰かがこれについての経験があり、できればコード例を共有していますか?

前もって感謝します！