最近，做一个 标题头 封装，是一个带有 搜索功能的 标题头；之前，结合学习的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()
}
