java - 收到 RxJava Debounce 方法调用

Question

我的意思是，我想对方法调用进行简单的限制。我有这个方法:

public void called(int number){
   doSomething(number);
}

此方法调用得太频繁，我想根据收到的数字创建一个可观察对象，并消除对doSomething(number)的调用。

这可能吗？

Answer 1

当然，就像这样 -

PublishSubject<Integer> subject = PublishSubject.create();

subject
  .debounce(1, TimeUnit.SECONDS)
  .subscribe(new Action1<Integer>() {
    public void call(Integer number) {
      doSomething(number);
    }
  });

public void called(int number){
  subject.onNext(number);   
}