使用 dispose 处理程序 rxjava 创建 Observable

Question

我们想观察视图大小的变化，我们创建一个这样的扩展：

fun View.layoutSizeObservable(): io.reactivex.Observable<Size> {
    return io.reactivex.Observable.create<Size> { emitter ->
        viewTreeObserver.addOnGlobalLayoutListener {
            Log.d("MainFragment", "ViewTreeObserver Listener called back.")
            if (measuredWidth > 0 && measuredHeight > 0) {
                emitter.onNext(Size(measuredWidth, measuredHeight))
            }
        }
    }
}

然后我们像这样使用它，它在功能上运行良好：

sizeChangedDisposable = titleTextView.layoutSizeObservable().subscribe { size: Size ->
    Log.d("MainFragment", "Size changed subscribe on $size")
}

然而，我们不想要的一件事是Listener 是通过addOnGlobalLayoutListener 添加的，但从未删除。

我们可以拨打sizeChangedDisposable.dispose()，它会正确停止订阅：

D/MainFragment：在 $size 上更改订阅大小

但这将继续被调用：

D/MainFragment：ViewTreeObserver 监听器回调。

我们如何以及在哪里删除布局侦听器回调？

Answer 1

当Disposable 被释放时，你需要移除监听器。为了能够做到这一点，请将Cancellable 操作设置为发射器移除听者。

示例

fun View.layoutSizeObservable(): io.reactivex.Observable<Size> {
    return io.reactivex.Observable.create<Size> { emitter ->
        val listener = ViewTreeObserver.OnGlobalLayoutListener {
            Log.d("MainFragment", "ViewTreeObserver Listener called back.")
            if (measuredWidth > 0 && measuredHeight > 0) {
                emitter.onNext(Size(measuredWidth, measuredHeight))
            }
        }

        viewTreeObserver.addOnGlobalLayoutListener(listener)

        emitter.setCancellable {
            Log.d("MainFragment", "ViewTreeObserver Listener removed.")
            viewTreeObserver.removeOnGlobalLayoutListener(listener)
        }
    }
}

顺便说一句，RxBinding 库已经有一个 Observable 用于 global layout listener