本文整理了Java中rx.Observable.throttleWithTimeout()方法的一些代码示例，展示了Observable.throttleWithTimeout()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Observable.throttleWithTimeout()方法的具体详情如下：
包路径：rx.Observable
类名称：Observable
方法名：throttleWithTimeout

Observable.throttleWithTimeout介绍

[英]Returns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window.

Note: If the source Observable keeps emitting items more frequently than the length of the time window then no items will be emitted by the resulting Observable.

Information on debounce vs throttle:

• Debounce and Throttle: visual explanation
• Debouncing: javascript methods
• Javascript - don't spam your server: debounce and throttle
  Backpressure Support: This operator does not support backpressure as it uses time to control data flow. Scheduler: throttleWithTimeout operates by default on the computation Scheduler.
  [中]返回一个Observable，该Observable仅发射源Observable发出的那些项，这些项在指定的时间窗口内没有后跟另一个已发射项。
  *注：*如果源可观测物持续发射项目的频率高于时间窗口的长度，则产生的可观测物不会发射任何项目。
  关于去盎司与油门的信息：
• Debounce and Throttle: visual explanation
• Debouncing: javascript methods
• Javascript - don't spam your server: debounce and throttle
  背压支持：该操作员不支持背压，因为它使用时间来控制数据流。调度程序：throttleWithTimeout默认在计算调度程序上运行。

代码示例

代码示例来源：origin: henrymorgen/android-advanced-light

private void throttleWithTimeOut() {
  Observable.create(new Observable.OnSubscribe<Integer>() {
    @Override
    public void call(Subscriber<? super Integer> subscriber) {
      for (int i = 0; i < 10; i++) {
        subscriber.onNext(i);
        int sleep = 100;
        if (i % 3 == 0) {
          sleep = 300;
        }
        try {
          Thread.sleep(sleep);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
      subscriber.onCompleted();
    }
}).throttleWithTimeout(200,TimeUnit.MILLISECONDS).subscribe(new Action1<Integer>() {
    @Override
    public void call(Integer integer) {
      Log.d(TAG, "throttleWithTimeOut:"+integer);
    }
  });
}

代码示例来源：origin: leeowenowen/rxjava-examples

@Override
 public void run() {
  Observable.create(new Observable.OnSubscribe<Integer>() {
   @Override
   public void call(Subscriber<? super Integer> subscriber) {
    for (int i = 0; i < 10; i++) {
     subscriber.onNext(i);
     sleep(500);
    }
    subscriber.onCompleted();
   }
  })
       .subscribeOn(Schedulers.newThread())
       .throttleWithTimeout(2, TimeUnit.SECONDS)
       .observeOn(Schedulers.newThread())
       .subscribe(new Action1<Integer>() {
        @Override
        public void call(Integer integer) {
         log(integer);
        }
       });
 }
});