kotlin 的 ‘协变’ 与 ‘逆变’

最近，做一个 标题头 封装，是一个带有 搜索功能的 标题头；之前，结合学习的debounce 操作的特性来完成 延时、过滤等操作，并用kotlin 重写一边逻辑，发现在 之前的 协变 、逆变的地方 卡住，原来kotlin 的用 in、out来 分别表示 ‘逆变’ 和 ‘协变’ 。

自己的java 代码（ref）

mRxManager.register(RxTextView.textChanges(searchEt)
        .subscribeOn(AndroidSchedulers.mainThread()) // 对etKey[EditText]的监听操作 需要在主线程操作
        .debounce(400, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
        //对用户输入的关键字进行过滤
        .filter(new Predicate<CharSequence>() {
            @Override
            public boolean test(@io.reactivex.annotations.NonNull CharSequence charSequence) throws Exception {
                if (charSequence.toString().trim().length() > 0) {
                    mRefreshLayout.setRefreshing(true);
                }
                return charSequence.toString().trim().length() > 0;
            }
        })
        .observeOn(Schedulers.io())//对下游的Observable起作用
        .switchMap(new Function<CharSequence, ObservableSource<QueryPagerBean>>() {
            @Override
            public Observable<QueryPagerBean> apply(@io.reactivex.annotations.NonNull CharSequence keyWord) throws Exception {
                mKeyWord = keyWord.toString().trim();
                LogUtils.d(TAG, "mKeyWord = " + mKeyWord);
                mPageIndex = PAGER_BEGIN;
                mPageSize = PAGER_SIZE;
                String content = new Gson().toJson(new XxxxPagerReq(mKeyWord, mPageIndex, mPageSize, mUserInfo.checkToken));
                LogUtils.d(TAG, "content = " + content);
                return RetrofitCreateHelper.createApi(ApiService.class, RetrofitCreateHelper.PAGER_CONVERTER)
                        .getXxxxPagerByKeyword(RequestBody.create(MediaType.parse("application/json; charset=utf-8"), content));

            }
        }))

由于是封装 组合式控件，在switchMap操作符的网络请求逻辑 ，是要暴露接口出去，让外部自由发挥的，参数是需要一个Function 对象，如图（注意 它有一个逆变 、两个协变）

屏幕快照 2018-06-28 上午11.55.38.png

现在看kotlin代码

RxTextView.textChanges(qt_search_et)
        .subscribeOn(AndroidSchedulers.mainThread()) // 对etKey[EditText]的监听操作 需要在主线程操作
        .debounce(400, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
        //对用户输入的关键字进行过滤
        .filter { charSequence ->
            if (charSequence.toString().trim().isNotEmpty()) {
                mSearchListener?.searchBeginning() // mRefreshLayout.setRefreshing(true)
            }
            charSequence.toString().trim().isNotEmpty() && mSearchListener != null && mSearchListener?.triggerSearchReq() != null
        }
        .observeOn(Schedulers.io())
        // 传递一个函数 过来（triggerSearchReq）
        .switchMap(mSearchListener?.triggerSearchReq())
        .compose(RxHelper.rxSchedulerHelper())
        // 数据处理，以及一些回调
        .subscribe(object : Consumer<QueryPagerBean> {
            override fun accept(queryPagerBean: QueryPagerBean) {
                mSearchListener?.getSearchResult(queryPagerBean)
            }
        }, object : Consumer<Throwable> {
            override fun accept(throwable: Throwable) {
                mSearchListener?.searchError()
                LogUtils.e(TAG, "call: throwable.toString() " + throwable.toString())
                LogUtils.e(TAG, "call: throwable.toMessage() " + throwable.message)
                throwable.printStackTrace()
            }
        }, object : Action {
            override fun run() {
                mSearchListener?.searchComplete()
            }
        })

private var mSearchListener: OnSearchListener? = null

fun setSearchListener(listener: OnSearchListener) {
    mSearchListener = listener
}

interface OnSearchListener {
    /** 点击取消  */
    fun onClickCancel()

    /** 搜索编辑框文字清空，通知数据集也要清空  */
    fun onClearClick()

    /** 开始触发搜索 */
    fun searchBeginning()

    /** 按 keyword 网络请求 数据（关注这个方法的 返回值，是一个Function对象） */
    fun triggerSearchReq(): Function<in CharSequence, out ObservableSource<out QueryPagerBean>>

    /** 获取 网络数据 搜索结果 */
    fun getSearchResult(queryPagerBean: QueryPagerBean)

    /** 搜索异常 */
    fun searchError()

    /** 搜索完成 */
    fun searchComplete()
}