3
這裏是我的代碼:如何使用RxBinding&Retrofit?
// Observable from RxView
RxView.clicks(mBtnLogin)
.throttleFirst(500, TimeUnit.MILLISECONDS)
.subscribe(new Action1<Void>() {
@Override
public void call(Void aVoid) {
String userName = mEditUserName.getText().toString();
String passWord = mEditPassWord.getText().toString();
if (TextUtils.isEmpty(userName)) {
Toast.makeText(LoginActivity.this, R.string.input_user_name, Toast.LENGTH_SHORT).show();
return;
}
if (TextUtils.isEmpty(passWord)) {
Toast.makeText(LoginActivity.this, R.string.input_pass_word, Toast.LENGTH_SHORT).show();
return;
}
LoginAction action = Constants.retrofit().create(LoginAction.class);
// Observable from Retrofit
Observable<String> call = action.login(userName, MD5.encode(passWord));
call.subscribeOn(Schedulers.io())
.subscribe(new Observer<String>() {
@Override
public void onCompleted() {
System.out.println("completed");
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onNext(String s) {
System.out.println("next" + s);
}
});
}
});
有沒有什麼可以結合從RxView的觀察到的,從改造中可觀察到什麼辦法?
我認爲代碼很醜,不符合ReactiveX的規範。
什麼是 'apiService'? http請求必須在後臺線程中,然後在主線程中獲取用戶名和密碼,如何執行此操作? –
在我的示例中,「apiService」是您使用Retrofit創建的服務。它使用'Schedulers.io()'在後臺線程上調用,然後在主線程上觀察結果。 – Orbit
但是當RxView.clicks(mButton)時你必須得到用戶名和密碼,你忘記了這一步。 –