Kotlin 协程版的 AutoDispose
因此大家一定会用到 Uber 的开源框架 AutoDispose。
什么？你说你没用？好吧，那就没用吧。。我是不会介绍它的。⊙﹏⊙|||。怎么可能。(～￣▽￣)～。。它其实就是利用 View 的 OnAttachStateChangeListener ，当 View 被拿下的时候，我们就取消所有之前用 RxJava 发出去的请求。
static final class Listener extends MainThreadDisposable implements View.OnAttachStateChangeListener {
private final View view;
private final CompletableObserver observer;
Listener(View view, CompletableObserver observer) {
this.view = view;
this.observer = observer;
}
@Override public void onViewAttachedToWindow(View v) { }
@Override public void onViewDetachedFromWindow(View v) {
if (!isDisposed()) {
//看到没看到没看到没？
observer.onComplete();
}
}
@Override protected void onDispose() {
view.removeOnAttachStateChangeListener(this);
}
}好了，我最近在想我们用协程其实也会有这样的问题呀：
button.onClick {
try {
val req = Request()
val resp = async { sendRequest(req) }.await()
updateUI(resp)
} catch (e: Exception) {
e.printStackTrace()
}
}如果 await 返回结果之前我们就退出了当前的 Activity 那么，后面 updateUI 就要凉凉。这就尴尬了。不过问题不大，照猫画虎谁不会，我们也可以搞一个 onClickAutoDisposable 嘛。
fun View.onClickAutoDisposable (
context: CoroutineContext = Dispatchers.Main,
handler: suspend CoroutineScope.(v: android.view.View?) -> Unit
) {
setOnClickListener { v ->
GlobalScope.launch(context, CoroutineStart.DEFAULT) {
handler(v)
}.asAutoDisposable(v)
}
}第一步，不要脸的先抄 Anko 的 onClick，不同之处在于我们改了个名 XD。啊，还有我们加了个 .asAutoDisposable(v)，大家就假装有这个方法吧。。。
(╬￣皿￣)=○ 假装个头啊，假装就完成功能的话还要程序员干什么。。让产品假装一下不就行了。。
OK OK，咱们下面来实现它。。想想， GlobalScope.launch 其实返回的是一个 Job，所以嘛，我们给 Job 搞一个扩展方法不就得了。
fun Job.asAutoDisposable(view: View) = AutoDisposableJob(view, this)第二步，我们再偷偷的创建一个类，叫 AutoDisposableJob，抄一下前面的 Listener：
class AutoDisposableJob(private val view: View, private val wrapped: Job)
//我们实现了 Job 这个接口，但没有直接实现它的方法，而是用 wrapped 这个成员去代理这个接口
: Job by wrapped, OnAttachStateChangeListener {
override fun onViewAttachedToWindow(v: View?) = Unit
override fun onViewDetachedFromWindow(v: View?) {
//当 View 被移除的时候，取消协程
cancel()
view.removeOnAttachStateChangeListener(this)
}
private fun isViewAttached() =
Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT && view.isAttachedToWindow || view.windowToken != null
init {
if(isViewAttached()) {
view.addOnAttachStateChangeListener(this)
} else {
cancel()
}
//协程执行完毕时要及时移除 listener 免得造成泄露
invokeOnCompletion() {
view.removeOnAttachStateChangeListener(this)
}
}
}这样的话，我们就可以使用这个扩展了：
button.onClickAutoDisposable{
try {
val req = Request()
val resp = async { sendRequest(req) }.await()
updateUI(resp)
} catch (e: Exception) {
e.printStackTrace()
}
}当 button 这个对象从 window 上撤下来的时候，我们的协程就会收到 cancel 的指令。
好的，我又凭实力忽悠了本周的文章。。。
本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。
原始发表：2019-01-07，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
腾讯云开发者
