java - 调用 void 方法并传递参数 RxJava

Question

我正在寻找更好的方法来做到这一点:

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 -> {                     
                });

但我想不出更好的办法。

Answer 1

mRestService 上的 start 方法会产生副作用。因此，您可以使用此处的 doOnNext 方法来实现这种副作用。

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