侦听器监听被限流器（throttle）丢弃的对象

可以使用RxJava的throttleWithTimeout操作符来实现限流并且监听被丢弃的流事件。

示例代码：

Observable.create(new ObservableOnSubscribe<Integer>() { @Override public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Exception { //模拟每200毫秒发送一个事件，共发送10个事件 for (int i = 0; i < 10; i++) { Thread.sleep(200); emitter.onNext(i); } emitter.onComplete(); } }) .throttleWithTimeout(500, TimeUnit.MILLISECONDS) //限流时间为500毫秒 .subscribe(new Consumer<Integer>() { @Override public void accept(Integer integer) throws Exception { System.out.println("接收到事件：" + integer); } }, new Consumer<Throwable>() { @Override public void accept(Throwable throwable) throws Exception { System.out.println("发生错误：" + throwable.getMessage()); } }, new Action() { @Override public void run() throws Exception { System.out.println("事件处理完成"); } });

输出：

接收到事件：0 接收到事件：2 接收到事件：4 接收到事件：6 接收到事件：8 事件处理完成