经常调用回调方法来将事件转发到可观察的？

Question

所以我在自定义滑块视图上有这个监听器。当用户滑动滑块时，视图调用“滑块已更改（整数百分比）”。当滑块更改时，我正在尝试进行网络调用，但我不想进行一百万次网络调用，因为该方法在滑动时经常被调用。如何使此侦听器回调为可观察量？我知道一旦它是可观察的，我就可以使用去抖动，并且仅在一定的时间间隔后更新。

我试着做了< code>Observable.create(),但是我在一个回调方法中，我不知道如何工作。我用的是Kotlin和RxJava2 btw。

override fun onSliderChanged(percent: Int)
{
    // Either here or in the presenter I want to make this 
    // callback reactive so I can debounce the callback
    presenter.onSliderChanged(percent)
}

Answer 1

从你的问题中看不出你是如何通过听众的，但有两种一般情况浮现在脑海中。选择一个与您的实现匹配的实现。

案例1：监听器作为接口传递

为此，我假设你也有一个类似的界面——

interface SliderChangedListener {
    fun onSliderChanged(percent: Int)
}

以及 Slider 类中的一个方法，该方法采用该侦听器的实例 -

fun setSlideListener(listener: SliderChangedListener) 

这是一种常见的Java模式。在静态编程语言中，删除接口并只传递一个函数变量会更容易，但是鉴于您在上面显示了覆盖，您的视图似乎来自Java。无论如何，关键是创建一个可观察的，并让它创建和设置调用onNext的侦听器。

Observable.create(Observable.OnSubscribe<Int> {
        subscriber ->
        slider.setSlideListener(object : SliderChangedListener {
            override fun onSliderChanged(percent: Int) {
                subscriber.onNext(percent)
            }
        })
    }).subscribe { /* respond to the slide */ }

案例2:您扩展了< code>Slider类并覆盖了侦听器

在这种情况下，我假设您的< code>Slider类中有一个侦听器方法，您可以用问题中的代码直接覆盖它。在这种情况下，我们可以使用< code>Subject在侦听器和订阅者之间进行调解。

val mySlider = object : Slider() {
        val sliderObservable: PublishSubject<Int> = PublishSubject.create()
        override fun onSliderChanged(percent: Int) {
            sliderObservable.onNext(percent)
        }
    }
mySlider.sliderObservable.subscribe({ /* do slider work */ })