@Override
public Observable<BaseData<User>> login(String phone, String password) {
return Observable.create(new Observable.OnSubscribe<BaseData<User>>() {
@Override
public void call(Subscriber<? super BaseData<User>> subscriber) {
BaseData baseData = DataEmulator.createEmptyBaseData();
subscriber.onNext(baseData);
subscriber.onCompleted();
}
});
}
public class DataEmulator {
public static BaseData createEmptyBaseData() {
BaseData baseData = new BaseData();
baseData.status = 1;
baseData.data = new ObjectData();
return baseData;
}
}
UserApi api = new UserApiImpl();
public void login(String phone, String password) {
if (!checkUserInput(phone, password)) return;
view.showLoading();
api.login(phone, password)
.compose(new ResponseTransformer<>(this.<BaseData<User>> bindLifeCycle()))
.subscribe(new ResponseSubscriber<BaseData<User>>(view) {
@Override public void success(BaseData<User> baseData) {
AuthorityContext.getContext().loggedIn();
RxBus.getDefault().send(new LoginCompletedEvent());
view.loginComplete();
}
});
}