RxAndroidが観測可能な状態でスイッチケースを処理する

Question

私のアンドロイドアプリケーションは、コマンドがアプリケーション内の他のコンポーネントにコールして結果を待つ必要があるため、別のコマンドとレスポンスを非同期で処理する必要があります。

rxjavaを使用して、受信した文字列を別のパラメータにマップしようとしましたが、別のコマンドを手動でルーティングする必要があります。ロジックをカスタマイズされた観測可能ノードにルーティングし、

コードは以下の通りです：

  Observable.just(command_string) 
      .map(new Func1<String, Command>() { 
       @Override 
       public Command call(String command_string) { 
        ......; 
       } 
      }) 
      .filter(new Func1<Command, Boolean>() { 
       @Override 
       public Boolean call(Command file) { 
        ThreadUtils.logThreadSignature(TAG); 
        return !isExcuetingCmd; 
       } 
      }) 
      .subscribeOn(Schedulers.io()) 
      .map(new Func1<Command, CmdResponse>() { 
       @Override 
       public CmdResponse call(Command command) { 
        //stupid code... 
        switch (cmd) 
        { 
         case CMD_1: 

          ... 
          CmdResponse = xxx 
          break; 

         case CMD_2: 
          ... 
          CmdResponse = xxx 
          break; 

         case CMD_3: 
          ... 
          CmdResponse = xxx 
          break;      
        } 
        return CmdResponse; 
       } 
      }) 
      .flatMap(new Func1<CmdResponse, Observable<String>>() { 
       @Override 
       public Observable<String> call(CmdResponse cmdResponse) { 
        return Observable.just(gson.toJson(CmdResponse)); 
       } 

      }); 

Answer 1

私はあなたが行うことができると思う何あなたのcmdResponseに応じて、あなたがグループにその観測可能を追加することができますので、その後、GROUPBY演算子を使用しています。最後に、観測可能な終了が出ると、加入者のグループを確認することができます。

公式ドキュメントここhttp://reactivex.io/documentation/operators/groupby.html

私はあなたがここにhttps://github.com/politrons/reactive