変数を "into"にして後で使用するRxJavaチェーン

Question

AndroidでRxJavaを使用してログイン操作を実行しています。

ユーザー名、パスワード、ブール値のフラグを渡す必要があります。ユーザー名とパスワードと検証のためにサーバーに送信され、応答が返されたら、次に何をするかを決定するためにフラグを使用する必要があります。

ログイン操作は非同期なので、応答が返っても私が最初に渡したユーザー名、パスワード、フラグにアクセスできるようにしたいと思います。

は、ここで私は問題を抱えていると信じていることを、私はこれをコード化された最初の方法です：

public Observable<Result> execute1(final String username, final String password, final boolean shouldSaveUsername) { 
    return mLoginNetwork 
      .loginWithCredentials(username, password) 
      .map(new Func1<Response<Void>, LoginObject>() { 
       @Override 
       public LoginObject call(Response<Void> response) { 
        if (!response.isSuccessful()) { 
         Exceptions.propagate(new HttpException(response)); 
        } 

        return new LoginObject(username, password, shouldSaveUsername); 
       } 
      }) 
      .doOnNext(new Action1<LoginObject>() { 
       @Override 
       public void call(LoginObject loginObject) { 
        if (loginObject.shouldSaveUsername) { 
         saveUsername(username); 
        } 
       } 
      }) 
      .flatMap(new Func1<Entitlement, Observable<Result>>() { 
       @Override 
       public Observable<Result> call(LoginObject loginObject) { 
        return mNetwork 
          .fetchSomething(); 
       } 
      }); 
} 

私は（）それは私がキャッシュし、その後に加入した観測を返すEXECUTE1を呼び出すとき。 Androidの設定が変更された場合、私はObservableから退会しますが、キャッシュに保持します。構成の変更が完了したら、Observableをキャッシュから取り出して再サブスクライブします。私はresubscribe loginWithCredentials呼び出しを再度行う必要がありますが、それはユーザー名、パスワード、ブール値フラグが存在しないので、私は問題である私のチェーンでそれらを使用することはできませんが返されます。

この問題を解決するにはどうすればよいですか？

Observableの入力データをObservableの一部にする方法が必要です。Observableをキャッシュすると、入力データもキャッシュされるようになります。ここで

は、以下の提案されたソリューションです：私がしようとしてる何

public Observable<Result> execute2(String username, String password, boolean shouldSaveUsername) { 
    return Observable 
      .just(new LoginData(username, password, shouldSaveUsername)) 
      .flatMap(new Func1<LoginData, Observable<LoginData>>() { 
       @Override 
       public Observable<?> call(final LoginData loginData) { 
        return mLoginNetwork 
          .loginWithCredentials(loginData.getUsername(), loginData.getPassword()) 
          .map(new Func1<Response<Void>, LoginData>() { 
           @Override 
           public LoginData call(Response<Void> response) { 
            if (!response.isSuccessful()) { 
             Exceptions.propagate(new HttpException(response)); 
            } 
            return loginData; 
           } 
          }); 
       } 
      }) 
      .doOnNext(new Action1<LoginData>() { 
       @Override 
       public void call(LoginData loginData) { 
        if (loginData.shouldSaveUsername) { 
         saveUsername(username); 
        } 
       } 
      }) 
      .flatMap(new Func1<LoginData, Observable<Result>>() { 
       @Override 
       public Observable<Result> call(LoginData loginData) { 
        return mNetwork 
          .fetchSomething(); 
       } 
      }); 
} 

Observable.justを（使用してすぐにストリームの入力データ部分を作ることです）、入力データを取ると、 Observableにして、残りの残りの操作を入力として受け取るようにします。私は今、観測可能なデータをキャッシュし、後で再登録すると、入力データが観測可能な状態に埋め込まれ、後でどの演算子でもアクセスできると仮定します。

「正常な」RxJava /機能的な方法で私の提案したソリューションで私の問題を解決しましたか？この問題にアプローチするより良い方法はありますか？

Answer 1

username/password/save-flagは、finalとマークされたパラメータとしてexecute1()に渡されます。次に、匿名のネストされたクラスでは、それらの値を明示的に参照し、それらを「クローズ」します。結果として得られる観測可能なチェーンには、動作するために必要なすべてのものがあります。

observableを再度購読すると、元のusername/password/save-flagが使用されます。