MVP+Retrofit+RxJava(Flowable)结合使用

MVP流程图：

compile 'io.reactivex.rxjava2:rxjava:2.1.7'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'

package com.bwie.com.myapplication.http;

import com.bwie.com.myapplication.bean.MessageBean;
import com.bwie.com.myapplication.bean.News;

import java.util.List;
import java.util.Map;

import io.reactivex.Flowable;
import retrofit2.http.GET;
import retrofit2.http.QueryMap;

/**
* Created by Wangrx on 2017/12/6.
*/

public interface ApiService {
@GET("93app/data.do")
Flowable<MessageBean<List<News>>> getNews(@QueryMap Map<String,String> map);
}

package com.bwie.com.myapplication.http;

import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;

/**
* Created by Wangrx on 2017/12/6.
*/

public class RetrofitUtils {
private static volatile RetrofitUtils instance;
private ApiService apiService;

private RetrofitUtils(){
Retrofit retrofit = new Retrofit.Builder()
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.baseUrl("http://www.93.gov.cn/")
.build();
apiService = retrofit.create(ApiService.class);
}
public static RetrofitUtils getInstance(){
if (null==instance){
synchronized (RetrofitUtils.class){
if (instance==null){
instance = new RetrofitUtils();
}
}
}
return instance;
}
public ApiService getApiService(){
return apiService;
}
}

package com.bwie.com.myapplication.model;

import java.util.Map;

/**
* Created by Wangrx on 2017/12/6.
*/

public interface IModel {
void getData(Map<String,String> map);
}

package com.bwie.com.myapplication.model;

import com.bwie.com.myapplication.bean.MessageBean;
import com.bwie.com.myapplication.bean.News;
import com.bwie.com.myapplication.http.RetrofitUtils;
import com.bwie.com.myapplication.presenter.NewsPresenter;

import java.util.List;
import java.util.Map;

import io.reactivex.Flowable;

/**
* Created by Wangrx on 2017/12/6.
*/

public class NewsModel implements IModel{
private NewsPresenter presenter;
public NewsModel(NewsPresenter presenter){
this.presenter = presenter;
}
@Override
public void getData(Map<String, String> map) {
Flowable<MessageBean<List<News>>> flowable = RetrofitUtils.getInstance().getApiService().getNews(map);
presenter.getNews(flowable);
}
}

package com.bwie.com.myapplication.presenter;

import java.util.Map;

/**
* Created by Wangrx on 2017/12/6.
*/

public interface BasePresenter {
void getData(Map<String,String> map);
}

package com.bwie.com.myapplication.presenter;

import com.bwie.com.myapplication.bean.MessageBean;
import com.bwie.com.myapplication.bean.News;
import com.bwie.com.myapplication.model.NewsModel;
import com.bwie.com.myapplication.view.Iview;

import java.util.List;
import java.util.Map;

import io.reactivex.Flowable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import io.reactivex.subscribers.DisposableSubscriber;

/**
* Created by Wangrx on 2017/12/6.
*/

public class NewsPresenter implements BasePresenter {
private Iview iv;
private DisposableSubscriber subscriber;

public void attachView(Iview iv) {
this.iv = iv;
}

public void detachView() {
if (iv != null) {
iv = null;
}
if (!subscriber.isDisposed()){
subscriber.dispose();
}
}

@Override
public void getData(Map<String, String> map) {
NewsModel model = new NewsModel(this);
model.getData(map);
}

public void getNews(Flowable<MessageBean<List<News>>> flowable) {
subscriber = flowable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(new DisposableSubscriber<MessageBean<List<News>>>() {
@Override
public void onNext(MessageBean<List<News>> listMessageBean) {
if (listMessageBean != null) {
List<News> list = listMessageBean.getData();
if (list != null) {
iv.onSuccess(list);
}
}
}

@Override
public void onError(Throwable t) {
iv.onFailed((Exception) t);
}

@Override
public void onComplete() {

}
});
}
}

package com.bwie.com.myapplication.view;

/**
* Created by Wangrx on 2017/12/6.
*/

public interface Iview {
void onSuccess(Object o);
void onFailed(Exception e);
}

package com.bwie.com.myapplication;

import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;

import com.bwie.com.myapplication.bean.News;
import com.bwie.com.myapplication.presenter.NewsPresenter;
import com.bwie.com.myapplication.view.Iview;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class MainActivity extends AppCompatActivity {

private NewsPresenter presenter;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//http://www.93.gov.cn/93app/data.do?channelId=0&startNum=0
Map<String, String> map = new HashMap<>();
map.put("channelId","0");
map.put("startNum","0");
presenter = new NewsPresenter();
presenter.getData(map);
presenter.attachView(new Iview() {
@Override
public void onSuccess(Object o) {
if (o instanceof List){
List<News> news = (List<News>) o;
Log.i("zzz", "onSuccess: "+news.size());
}
}

@Override
public void onFailed(Exception e) {
Log.i("zzz", "onSuccess: "+e.getMessage());
}
});
}

@Override
protected void onDestroy() {
super.onDestroy();
if (presenter!=null){
presenter.detachView();
}
}
}