Skip to content

Instantly share code, notes, and snippets.

@bangarharshit
Last active October 19, 2016 17:26
Show Gist options
  • Save bangarharshit/22555be65615af667afdeeac75dcce53 to your computer and use it in GitHub Desktop.
Save bangarharshit/22555be65615af667afdeeac75dcce53 to your computer and use it in GitHub Desktop.
ConnectableObservable<String> remoteUserIdObservable =
mUserClient
.login()
.map(this::checkNonNull)
.doOnNext(this::logIn)
.map(UserModel::_id);
Observable<String> outputObservable = Observable
.concat(mSessionManager.getUserIdAsObservable(), remoteUserIdObservable);
public Observable<String> getUserIdAsObservable() {
return rxSharedPreferences
.getString(USER_LOGIN_KEYS.LOGIN_USER_ID.toString())
.asObservable();
}
@GET("/user")
Observable<UserModel> login();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment