实现功能：

网络数据请求，缓存，等待窗口，刷新加载，recyclerview封装。

知识点：

Rxjava2+retrofit2+okhttp3网路请求，Glide图片加载，recyclerview使用，自定义控件。

网络结构图：

RxjavaActivity.png

使用说明:

导入包

Rxjava依赖包.jpg

清单文件

注意关联MyApplication，并用自己的application继承，这里用RxApp继承

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.haoyan.rxjava2">

    <uses-permission android:name="android.permission.INTERNET" />
    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
    <uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
    <uses-permission android:name="android.permission.READ_PHONE_STATE" />
    <uses-permission android:name="android.permission.READ_PROFILE"/>
    <uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS"/>

    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:roundIcon="@mipmap/ic_launcher_round"
        android:supportsRtl="true"
        android:name=".MyApplication"
        android:theme="@style/AppTheme">
        <activity android:name=".RxjavaActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />
                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>

其它

加载刷新用values文件下attrs.xml

<?xml version="1.0" encoding="utf-8"?>
<resources>

    <declare-styleable name="SwipyRefreshLayout">
        <attr name="direction">
            <enum name="top" value="0" />
            <enum name="bottom" value="1" />
            <enum name="both" value="2" />
        </attr>
    </declare-styleable>

</resources>

主类RxjavaActivity

public class RxjavaActivity extends AppCompatActivity {
    private static final String TAG = "MainActivity";
    private RecyclerView mRecyclerView;
    // private TextView mTextView;
    private CommonAdapter<RxMovieBean.SubjectsBean> commonadapter;
    private SwipyRefreshLayout swipeRefreshLayout;

    private Dialog loading_dialog;
    private List<RxMovieBean.SubjectsBean> storiesList;

    private final int TOP_REFRESH = 1;
    private final int BOTTOM_REFRESH = 2;
    int start=0;   //开始请求位置
    int pages=10;   //需要请求的数据数量
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_rxjava);
        initView();
        dataView(start,pages);
        setListener();
    }
    private void initView() {
        storiesList=new ArrayList<>();
        swipeRefreshLayout = (SwipyRefreshLayout) findViewById(R.id.swipeRefreshLayout);
        mRecyclerView = (RecyclerView)findViewById(R.id.id_stickynavlayout_innerscrollview);
        mRecyclerView.setLayoutManager(new GridLayoutManager(this,2));
        loading_dialog = new AlertDialog.Builder(this).setMessage("loading...").create();
        commonadapter = new CommonAdapter<RxMovieBean.SubjectsBean>(this,R.layout.rxjava_grid_item,storiesList) {
            @Override
            public void convert(ViewHolder holder, RxMovieBean.SubjectsBean subjectsBean) {
                ImageView imgview=holder.getView(R.id.imageIv);
                Glide.with(holder.itemView.getContext())
                        .load(subjectsBean.getImages().getLarge()).into(imgview);
                holder.setText(R.id.descriptionTv,subjectsBean.getTitle());
            }
        };
        mRecyclerView.setAdapter(commonadapter);
        commonadapter.setOnItemClickListener(new OnItemClickListener() {
            @Override
            public void onItemClick(ViewGroup parent, View view, Object o, int position) {
                Toast.makeText(RxjavaActivity.this, "位置"+position, Toast.LENGTH_SHORT).show();
            }

            @Override
            public boolean onItemLongClick(ViewGroup parent, View view, Object o, int position) {
                return false;
            }
        });
    }
    /**
     *调用说明
     * 1.调用RxSingleRxHttp
     * 2.关联url
     * 3.开启缓存
     * 4.读取时间
     * 5.关联api接口
     * 6.api接口中具体内容
     * 7.添加分支，等待框
     * 8.订阅
     * */
    private void dataView(int start,int pag) {
        RxHttpUtils.getSInstance()
                .baseUrl(RxUrl.BASE_URL)
                .cache(true)
                .readTimeout(500)
                .createSApi(Rxdoubanapi.class)
                .fetchMovieTop250(start, pag)
                .compose(RxTransformer.<RxMovieBean>switchSchedulers(loading_dialog))
                .subscribe(new RxCommonObserver<RxMovieBean>(loading_dialog) {
                    @Override
                    protected void getDisposable(Disposable d) {
                    }

                    @Override
                    protected void onError(String errorMsg) {
                    }

                    @Override
                    protected void onSuccess(RxMovieBean eMovieBean) {
                        storiesList.addAll(eMovieBean.getSubjects());
                        commonadapter.notifyDataSetChanged();
                        showToast("请求成功");
                    }
                });
    }
    private void setListener() {
        swipeRefreshLayout.setOnRefreshListener(new SwipyRefreshLayout.OnRefreshListener() {
            @Override
            public void onRefresh(int index) {
                Log.i(TAG, "onRefresh: "+index);
                dataOption(TOP_REFRESH);
            }

            @Override
            public void onLoad(int index) {
                Log.i(TAG, "onLoad: "+index);
                dataOption(BOTTOM_REFRESH);
            }
        });
    }
    private void dataOption(int option){
        switch (option) {
            case TOP_REFRESH:
                pages=10;
                dataView(0,pages);
                storiesList.clear();
                break;
            case BOTTOM_REFRESH:
                if(start>30){
                    Toast.makeText(RxjavaActivity.this, "到头了亲", Toast.LENGTH_SHORT).show();
                }else{
                    start=start+10;
                    dataView(start,pages);
                }
                break;
        }
        swipeRefreshLayout.setRefreshing(false);
        commonadapter.notifyDataSetChanged();
    }
}

被观察者核心代码：

public class RxRetrofitClient {
    private static RxRetrofitClient instance;
    private Retrofit.Builder mRetrofitBuilder;
    private OkHttpClient.Builder mOkHttpBuilder;

    public RxRetrofitClient() {

        mOkHttpBuilder = new OkHttpClient.Builder();

        mRetrofitBuilder = new Retrofit.Builder()
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create())
                .client(mOkHttpBuilder.build());
    }


    public static RxRetrofitClient getInstance() {

        if (instance == null) {
            synchronized (RxRetrofitClient.class) {
                if (instance == null) {
                    instance = new RxRetrofitClient();
                }
            }

        }
        return instance;
    }


    public Retrofit.Builder getRetrofitBuilder() {
        return mRetrofitBuilder;
    }

    public Retrofit getRetrofit() {
        return mRetrofitBuilder.client(mOkHttpBuilder.build()).build();
    }
}

观察者核心代码：

public abstract class RxBaseObserver<T> implements Observer<T>, RxISubscriber<T> {
    private Toast mToast;
    public static final String errorMsg_SocketTimeoutException = "网络链接超时，请检查您的网络状态，稍后重试！";
    public static final String errorMsg_ConnectException = "网络链接异常，请检查您的网络状态";
    public static final String errorMsg_UnknownHostException = "网络异常，请检查您的网络状态";

    protected void doOnNetError() {
    }

    @Override
    public void onSubscribe(@NonNull Disposable d) {
        doOnSubscribe(d);
    }

    @Override
    public void onNext(@NonNull T t) {
        doOnNext(t);
    }

    @Override
    public void onError(@NonNull Throwable e) {
        if (e instanceof SocketTimeoutException) {
            setError(errorMsg_SocketTimeoutException);
        } else if (e instanceof ConnectException) {
            setError(errorMsg_ConnectException);
        } else if (e instanceof UnknownHostException) {
            setError(errorMsg_UnknownHostException);
        } else {

            String error = e.getMessage();
            showToast(error);
            doOnError(error);
        }
    }


    @Override
    public void onComplete() {
        doOnCompleted();
    }


    private void setError(String errorMsg) {
        showToast(errorMsg);
        doOnError(errorMsg);
        doOnNetError();
    }


    /**
     * Toast提示
     *
     * @param msg 提示内容
     */
    protected void showToast(String msg) {
        if (mToast == null) {
            mToast = Toast.makeText(RxApp.getInstance(), msg, Toast.LENGTH_SHORT);
        } else {
            mToast.setText(msg);
        }
        mToast.show();
    }

    /**
     * 错误处理
     *
     * @param e
     * @return
     */
    private String handleError(Throwable e) {
        String error = null;
        try {
            ResponseBody errorBody = ((HttpException) e).response().errorBody();
            error = errorBody.string();
        } catch (IOException e1) {
            e1.printStackTrace();
        }

        return error;
    }
}

具体实现请看源码
补充：BaseObserver中的T可继承BaseResponse对code和msg同一处理，处理地点在BaseObserver的onNext中。
注意：Gilde4.0-RC1可能出现图片加载异常，替换Gilde4.0可修复
参考：
Rxjava2 学习（九篇容易理解）good
Rxjava1学习（大神级教程）good
封装完整版
okhttp