さまざまな http エンドポイントからカテゴリ、場所、アイテムを取得する 3 つの Angular2 サービスを作成しました。これらのサービスからデータを取得し、取得したすべてのデータから新しい DataSet を作成する新しいサービスを作成したいのですが、反復不可能な DataSet オブジェクトから Observable を作成できません。

Observables を使用している場合のように、データを単一の構造に統合するより良い方法はありますか?

リアクティブ オブジェクトに基づいて、ダッシュボード ヘッダーのドロップダウン メニューまたは通知項目をレンダリングすることは可能ですか? 私の試みはうまくいきませんでした。

Stomp over Websockets 用の小さな RxJS ラッパーを構築していますが、これは既に動作しています。

しかし今、私は本当にクールな機能のアイデアを思いつきました.RxJSを使用して簡単に実行できる可能性があります.

現在の動作:

ご覧のとおり、に登録するには を待たなければなりません。そうしないと、Stomp ライブラリからエラーが発生します。state == "CONNECTED"subscribeDestination(..)

新しい動作:

次の実装では、ユーザーにとって物事がより簡単になるはずです。これが私が想像するものです：

内部でどのように動作するか:

1. configure間のみ呼び出すことができますDISCONNECTED
2. がsubscribeDestination呼び出されると、次の 2 つの可能性があります。
   1. if CONNECTED: 宛先にサブスクライブするだけ
   2. if DISCONNECTED: 最初に呼び出しconnect()、次に宛先にサブスクライブする
3. がunsubscribe呼び出されると、次の 2 つの可能性があります。
   1. これが最後のサブスクリプションの場合: 呼び出しdisconnect()
   2. これが最後のサブスクリプションでない場合: 何もしない

そこにたどり着く方法はまだわかりませんが、それがここでこの質問をする理由です;-)

前もって感謝します！

編集:より多くのコード、例、説明

切断されていないときにconfigure()が呼び出されると、 . しかし、それは大したことではありません。Error

stompClient.connect(..)はノンブロッキングです。onSuccessコールバックがあります:

observeDestination(..)は、Stomp メッセージ チャネル (= 宛先) にサブスクライブし、Rx.Observableこの Stomp メッセージ チャネルからサブスクライブ解除するために使用できる を返します。

次のように使用できます。

今、私は取り除きたいと思いますmyStompWrapper.connect()。this.connect()コードは、最初のコードが呼び出しによってサブスクライブしたときに自動的に呼び出され、最後のコードが呼び出されたときに呼び出すobserveDestination(..).subscribe(..)必要があります。this.disconnect()unsubscribe()

例：

次のコードについて助けていただければ幸いです。

アプリにプロットとハンドソン可能なオブジェクトがあります。セルをクリックすると、対応するプロットがしきい値とともに読み込まれます。プロットをクリックすると、垂直線の 1 つの位置が変わります。

プロットをクリックして対応するセルに x 値を取得したいのですが、セルにも値を入力して垂直線の位置を設定できるようにしたいと考えています。

私は現在、値を reactValue データフレームにフィードバックする方法に少しこだわっています。

よろしくお願いします。