Retrofit RxJavaのネストされたオブザーバブルの循環推論

Question

rxJavaの新しい機能私は、ネスト化されたオブザーバブルによってObservableを取得するために苦労しています。 コードブロックについて.map(userResponse -> { data.put final Intent resd = new Intent(); resd.putExtras(data); return (Intent)resd; });

私は周期的推論エラーを受け取ります。 私がコンパイルしようとすると、私は私はかなりのように理解していない奇妙なメッセージが出ます：ここ

Error:(52, 21) error: incompatible types: cannot infer type-variable(s) R (argument mismatch; bad return type in lambda expression Intent cannot be converted to Observable) where R,T are type-variables: R extends Object declared in method flatMap(Func1>) T extends Object declared in class Observable

コードは次のとおりです。

public Observable<Intent> createUser(final String email) { 
    Bundle data = new Bundle(); 
    return mWebservice.clientAuth("myFakeClientId") //returns an Observable<AccessToken> 
      .map(clientTokenObject -> { 
       String clientToken = clientTokenObject.accessToken; 
       Observable<Response<User>> userResponseObservable = mWebservice.createAccount(email); 
       Observable<Intent> resultObs = userResponseObservable 
           .map(userResponse -> { 
            final Intent resd = new Intent(); 
            resd.putExtras(data); 
            return (Intent)resd; 
           }); 
         return resultObs; 
        }); 
} 

;（

Answer 1

あなたのマッピングが間違っているあなたを。

public Observable<Intent> createUser(final String email) { 

    return mWebservice.clientAuth("myFakeClientId") //returns an Observable<AccessToken> 
         .map(clientTokenObject -> clientTokenObject.accessToken) 
         .flatMap(accessToken -> { mWebservice.createAccount(email). 
                 .map(userResponse -> { 
                   final Intent resd = new Intent(); 
                   Bundle data = new Bundle(); 
                   resd.putExtras(data); 
                   return (Intent)resd; 
                  })}); 

}

ようなものが必要