这是Android中的RxJava

我有一个点击监听器,里面有:

oETASubject.onNext(center);


oETASubject是使用以下命令创建的PublishSubject<LatLng>

oETASubject = PublishSubject.create();


对这个问题的观察如下:

oETASubject
            //.throttleLast(100, TimeUnit.MILLISECONDS, Schedulers.io())
            //.debounce(100, TimeUnit.MILLISECONDS, Schedulers.io())
            .flatMap(latLng -> {
                // here is a http call with retrofit that returns an observable
                return returnAnAPIcallObservableHere(latLng);
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(myObserver);


我的问题:

如果使用throttleLastdebounce,则不会得到任何结果。
有什么办法可以让我每100毫秒限制一次请求,然后获取最后一个值?

最佳答案

线程错误!我去了:

.throttleLast(2, TimeUnit.SECONDS, AndroidSchedulers.mainThread())

09-25 21:43