网络请求框架

Administrator

2021-11-09 5f50bd6ea5d5bdb7b8ea4d9e9a5851067b9aec1b

 app/src/main/java/com/duqing/missions/ui/login/view/LoginActivity.java

@@ -21,6 +21,12 @@
import com.duqing.missions.R;
import com.duqing.missions.base.activities.BaseTitleBarActivity;
import com.duqing.missions.databinding.ActivityLoginBinding;
import com.duqing.missions.retrofit.RetrofitUtils;
import com.duqing.missions.retrofit.api.LoginApiCenter;

import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;


public class LoginActivity extends BaseTitleBarActivity<ActivityLoginBinding,LoginViewModel> {
@@ -116,8 +122,48 @@
        loginButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                viewModel.login(phoneEdit.getText().toString(),
                        passwordEditText.getText().toString());
                /*RetrofitUtils.getInstance().getRetrofit(LoginApiCenter.class).login(";lajks;dkfjal;ksjdf")

                        .subscribeOn(Schedulers.io())//指定网络请求在io后台线程中进行
                        .observeOn(AndroidScheduler.mainThread())//指定observer回调在UI主线程中进行
                        .subscribe(new io.reactivex.Observer<Object>() {
                            @Override
                            public void onSubscribe(Disposable d) {
                                v.setEnabled(false);
                                Log.d(TAG,"onSubscribe");
                            }

                            @Override
                            public void onNext(Object value) {
                                Log.d(TAG,"onNext value:"+value);

                            }

                            @Override
                            public void onError(Throwable e) {
                                v.setEnabled(true);
                                Log.d(TAG,"onError "+e.getMessage());

                            }

                            @Override
                            public void onComplete() {
                                v.setEnabled(true);
                                Log.d(TAG,"onComplete");

                            }
                        });//发起请求，请求的结果会回调到订阅者observer中*/
                RetrofitUtils.getInstance().getRetrofit(LoginApiCenter.class).loginCall("asdfasdfasdfasdfasdf").enqueue(new Callback<Object>() {
                    @Override
                    public void onResponse(Call<Object> call, Response<Object> response) {

                    }

                    @Override
                    public void onFailure(Call<Object> call, Throwable t) {

                    }
                });
            }
        });