如何在java中去除改进的反应请求？

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