問題タブ [subject-observer]

ルートが次のように見えるさまざまなルーターリンクに再利用したいコンポーネントが1つあります。

コンポーネントは、ルーター リンクごとに異なる場所から取得する必要があります。問題は、コンポーネントがサービスにサブスクライブし、別のルーター リンクに移動するたびにサブスクリプションが積み重なることです。この問題を解決するにはどうすればよいですか?

私はRxJavaを実行しており、onNext()メソッドを使用してデータを生成するサブジェクトを作成しています。私は春を使用しています。

これは私のセットアップです：

RxJava ストリームで新しいデータを生成する方法は@Autowire private SubjectObserver subjectObserver 、呼び出してから呼び出すことです。subjectObserver.publish(newDataObjGenerated)

subscribeOn()&に何を指定してもobserveOn():

• Schedulers.io()
• スケジューラー.計算()
• 私のスレッド
• Schedulers.newThread

とそのonNext()内部の実際の作業はonNext()、対象の を実際に呼び出してデータを生成/生成するのと同じスレッドで行われます。

これは正しいです？もしそうなら、私は何が欠けていますか? doSomething()別のスレッドで行われることを期待していました。

アップデート

私の呼び出しクラスでは、メソッドを呼び出す方法を変更するとpublish、もちろん、サブスクライバーが実行される新しいスレッドが割り当てられます。

ありがとう、

ディレクティブによって発行されたイベントを手動でサブスクライブしたいと考えています。これは、設計上、アプリケーションの複数のコンポーネントで利用できるようになっている必要があります。現時点では、構造は次のようになります。

app.moduleは次のようになります。

開発の後半では、別の親コンポーネントがドラッグ可能なディレクティブをリッスンし、独自のロジックを実装します。

子コンポーネントはどれも、ドラッグ可能なディレクティブがそれに何かをしていることを認識していません (または気にする必要はありません)。親コンポーネントが必要です。したがって、親コンポーネントでは:

そして、他の場所で推奨されているように、EventEmitter ではなく Subject を使用するディレクティブを次に示します。

正しい値で「発行」するコンソール ログを取得します。コンソールの親コンポーネントから「リッスン」することはありません。ここで何が間違っていますか？

内部で Rx.Subject を使用する関数からオブザーバブルを返そうとしています。もちろん、優れた API と同様に、実装の詳細は消費者から完全に抽象化する必要があります。ただし、Subject.asObservable() を使用すると、任意の消費者がすべてのオブザーバーに新しい値を発行できるように見えます。

例：

私の質問は、元のサブジェクトへのアクセスを許可せずに Observable を消費者に公開する組み込みの方法はありますか? そうでない場合、これは明らかに RxJ 側の悪い設計です。

注: これは RxJS v5 用です

キューのように使用する BlockCollection の Observable があります

そして彼を購読してください：

今、私は別のオブザーバブルを持っています:

OnTimerNextSubscribeが_subscriptionの購読を停止し、OnTimerNextSubscribe が終了したときにそれを更新し始めたときに希望します。

それに最適なパラクティスは何ですか？_subscriptionを破棄してStartSubscription()を呼び出す
必要がありますか

私は単純なBehaviorSubject、

実行stStatus()すると、コンソールに次の出力がログに記録されます。

値を期待している間

実装の何が問題になっていますか?