問題タブ [rx-scala]

オブジェクトのツリーを依存関係の逆順で観察したいのですが、どのコンビネータを使用すればよいかわかりません。特定のケースでは、削除のために AWS リソースを反復処理します。たとえば、次のように、S3 バケットを削除する前に S3 オブジェクトを削除します。

したがって、最後のcombinedオブザーバブルは、バケットを発行する前にすべてのオブジェクトを発行する必要があります。そのためにどのコンビネーターを使用する必要がありますか?

オブザーバブルが特別に必要です。

通常、私のオブザーバブルは別のスレッドで実行されます。ただし、サブスクリプションの途中で別のスレッドをブロックする必要がある場合があります。未来の振る舞いのようなもの。

例：

突然、さらに別のスレッドでイベントが発生し、現在のスレッドにサブスクリプションの実行を待機するよう通知しますs。(例は、Android のonPause.)

それ、どうやったら出来るの？sサブスクリプションを待ち、すべての結果を取得するにはどうすればよいですか?

（科目？）

質問の表現が不十分でしたら申し訳ありませんが、最善を尽くします。

U が値で、T が時間のような型 (または私が推測するもの) である、時間を含む値のシーケンスがある場合Observable[(U,T)]、自動リセットのワンタッチ バリアである演算子をどのように記述できますか? 、 の場合は無音ですabs(u_n - u_reset) < barrierが、バリアに触れると吐き出しt_n - t_reset、その時点で もリセットされますu_reset = u_n。

つまり、このオペレーターが受け取る最初の値がベースラインになり、何も出力しません。それ以降、ストリームの値を監視し、そのうちの 1 つがベースライン値を超える (上または下) とすぐに、経過時間 (イベントのタイムスタンプによって測定) を発行し、ベースラインをリセットします。これらの時間は、ボラティリティの高頻度推定値を形成するために処理されます。

参考までに、 http: //www.amazon.com/Volatility-Trading-CD-ROM-Wiley/dp/0470181990で概説されているボラティリティ推定器を作成しようとしています。 )、固定バリア量のバリアを突破するのにかかる時間を繰り返し測定します。

具体的には、これは既存の演算子を使用して記述できますか? 状態がどのようにリセットされるかについては少し固執していますが、1 つはワンショットで、もう 1 つはそのワンショットを作成し続ける 2 つのネストされたオペレーターを作成する必要があるかもしれません... 1つは手作業ですが、独自の発行者などを作成する必要があります.

ありがとう！

scala ワークシートで RxScala と Subject をいじっていました。しかし、奇妙なことが起こりました。

ご覧のとおり、サブスクリプション c も数値を取得して出力します。その後、サブスクリプション c が var ではなく val であることがわかりました。だから、私は宣言を変更します。そして、フォローしてください

これは正しいです。そのため、これらのコードをメイン関数にコピーして実行します。c が val であるかどうかにかかわらず、出力が 2 番目の図と同じであることは興味深いことです。

なぜそれらが起こったのですか？ワークシートで実行するプログラムは、同じコードでもコンパイル後のプログラムとは異なりますか?

誰かがここでヒントをくれないかと思っていました。私は RxScala を学んでおり、次の演習を行う必要があります: - 5 秒ごとおよび 12 秒ごとにイベントを発行するオブザーバブル オブジェクトを実装します。

次のコードがそれを行うかどうか疑問に思っていましたか? OBservable コンビネータの多くのドキュメントを見つけることができませんでした

マルコに感謝します

大きな Observable グラフ (つまりmerge、groupBy、joinなどを使用して何度も構成された Observable ) があり、例外がスローされた場合、例外の発生元を特定するのが難しい場合があります。ソース ファイルのどこで Observable オペレータが呼び出されたかを確認できるかどうかを知りたいです。例はこれをより明確にするはずです。

たとえば、次IllegalStateException: Only one subscriber allowed!のスタック トレースが与えられた場合、ソース ファイルのどの行番号、などが呼び出されたかを調べることができるかどうかを知りたいです。operatorMergeoperatorFilteroperatorGroupByデバッガー、print ステートメントなどを使用して、何らかの方法でこれを行うことは可能ですか?

この問題は基本的に、Observable の全体的なポイントは、実行時に a) コードを b) から分離することであるために発生します。しかし、プログラムをデバッグするのは悪夢です。上記の質問を繰り返しますが、各構成をソースコードの元の行まで追跡できるかどうかを知りたいです。

私は reactx とrxscalaObservableの初心者で、次のようなものを作成できます。

subscriberの中に新しい弦を入れることができますObservable.apply。

observable外部更新は可能ですか？つまり、次のような方法はありますかputNext:

既存のオブザーバブルに新しいものを入れさせるには？

からすべての履歴データを取得する方法はPublishSubject?

それは印刷します：

b: 1印刷されていないことがわかります。

(複数の場所からオブザーバブルを更新する必要があるため) 使用するPublishSubject必要がある場合、後のサブスクライバーもすべての履歴データを取得できるようにするにはどうすればよいですか?