RxJava2和Retrofit2封装教程（整洁、简单、实用）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了RxJava2和Retrofit2封装教程（整洁、简单、实用），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2445字，纯文字阅读大概需要4分钟。

内容图文

前言

RxJava2与Retrofit2是老搭档了，之前写了一篇《RxJava和Retrofit2的统一处理单个请求》，是用的Rxjava1.0，本次使用Rxjava2.0与Retrofit2进行封装，一样整洁、简单、实用。Rxjava2相比Rxjava1优化和改动不少了东西，网上有很多大神写的文章，这里就不粘贴复制了。封装的过程有什么问题、疑问，请在下方留言。
下面话不多说了，来一起看看详细的介绍吧

封装教程如下：

核心网络请求：

package com.lin.netrequestdemo.data;

import android.util.Log;

import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;

public class RxNet {
/**

• 统一处理单个请求

• @param observable

• @param callBack

• @param
  */
  public static Disposable request(Observable<BaseResponse> observable, final RxNetCallBack callBack) {
  return observable.subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .onErrorReturn(new Function<Throwable, BaseResponse>() {
  @Override
  public BaseResponse apply(Throwable throwable) {
  Log.e("LinNetError", throwable.getMessage());
  callBack.onFailure(ExceptionHandle.handleException(throwable));
  return null;
  }
  })
  .subscribe(new Consumer<BaseResponse>() {
  @Override
  public void accept(BaseResponse tBaseResponse) {
  if (tBaseResponse.getCode().equals("200")) {
  callBack.onSuccess(tBaseResponse.getData());

  } else {
  callBack.onFailure(tBaseResponse.getMsg());
  }
  }
  }, new Consumer() {
  @Override
  public void accept(Throwable throwable) {
  Log.e("LinNetError", "单个请求的错误" + throwable.getMessage());
  }
  });
  }

/**

• 统一处理单个请求
• 返回数据没有body
  */
  public static Disposable requestWithoutBody(Observable observable,
  final RxNetCallBack callBack) {
  return observable.subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .onErrorReturn(new Function<Throwable, BaseResponse>() {
  @Override
  public BaseResponse apply(Throwable throwable) {
  Log.v("LinNetError", throwable.getMessage());
  callBack.onFailure(ExceptionHandle.handleException(throwable));
  return null;
  }
  })
  .subscribe(new Consumer() {
  @Override
  public void accept(BaseResponse baseResponse) {
  if (baseResponse.getCode().equals("200")) {
  callBack.onSuccess(baseResponse.getMsg());
  } else {
  callBack.onFailure(baseResponse.getMsg());
  }
  }
  }, new Consumer() {
  @Override
  public void accept(Throwable throwable) {
  Log.v("LinNetError", "单个请求的错误:没有body" + throwable.getMessage());
  }
  });

内容总结

以上是互联网集市为您收集整理的RxJava2和Retrofit2封装教程（整洁、简单、实用）全部内容，希望文章能够帮你解决RxJava2和Retrofit2封装教程（整洁、简单、实用）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端