コールvoidメソッドと私はこれを行うには、より良い探していますRxJava

Question

trought引数を渡す：

mRestService.login(email, password) // Login user in 
       .flatMap(user -> Observable.zip(
         mRestService.start(user._token), // Start his session 
         Observable.just(user), 
         (v, u) -> (User) u // Pass user throught 
       )) 
       .subscribe(user -> { 
       }, throwable -> {      
       }); 

をしかし、私はより良い何かを思い付くcoudn't。

Answer 1

flatMapでmRestService.start（user._token）を呼び出す必要があります。ユーザーオブジェクトは、使用できるサブスクリプションに渡されます。

mRestService.login(email, password) // Login user in 
       .flatMap((user -> mRestService.start(user._token))) 
       .subscribe(user -> { 
       }, throwable -> { 
       }); 

Answer 2

mRestServiceにstart方法は副作用を実行します。したがって、この種の副作用のためにここにあるdoOnNextメソッドを使用することができます。

mRerstService.login(email, password) 
       .doOnNext(u -> mRestService.start(user._token)) 
       .subscribe();