我正在开发一个android项目,通过使用Rx-Java observable和subscribe进行改造来发出请求.
但是,在某些交互中,可以多次调用此请求,我只想在预定义的时间窗口(debounce)中执行最后一个请求.
我尝试将debounce运算符直接应用于observable,但它不起作用,因为每次发生某些交互时都会执行以下代码:
mAPI.getonlineUsers() .debounce(1, TimeUnit.SECONDS) .subscribe(...)
我想它应该只创建一个observable和每次交互它应该将执行“附加”到同一个observable.但我对Rx Java有点新意,并不确切知道该怎么做.
谢谢!
解决方法:
假设您想根据某些触发事件开始执行.
Observable<Event> trigger = ... // e.g. button clicks
您可以将触发器事件转换为对API的调用,如下所示:
trigger .debounce(1, TimeUnit.SECONDS) .flatMap(event -> mAPI.getonlineUsers()) .subscribe(users -> showThemSomewhere(users));
另外,请注意debounce运算符将在时间范围内进行最后一次出现,但throttlefirst将采用第一次出现.根据您的使用情况,您可能想要使用其中一个.
总结以上是内存溢出为你收集整理的如何在java中去除改进的反应请求?全部内容,希望文章能够帮你解决如何在java中去除改进的反应请求?所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)