这是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);
我的问题:
如果使用
throttleLast
或debounce
,则不会得到任何结果。有什么办法可以让我每100毫秒限制一次请求,然后获取最后一个值?
最佳答案
线程错误!我去了:
.throttleLast(2, TimeUnit.SECONDS, AndroidSchedulers.mainThread())