我正在开发一个android项目,通过使用Rx-Java observable和subscribe进行改造来发出请求.
但是,在某些交互中,可以多次调用此请求,我只想在预定义的时间窗口(debounce)中执行最后一个请求.
我试图将debounce运算符直接应用于observable,但它不起作用,因为每次发生某些交互时都会执行以下代码:
mApi.getOnlineUsers()
.debounce(1, TimeUnit.SECONDS)
.subscribe(...)
我想它应该只创建一个observable和每次交互它应该将执行"附加"到同一个observable.但我对Rx Java有点新意,并不确切知道该怎么做.
谢谢!