我正在开发一个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将采用第一次出现.根据您的使用情况,您可能想要使用其中一个.