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

Scheduler.schedule介绍

暂无

代码示例

代码示例来源：origin: com.github.mrstampy/esp

@Override
public void triggerProcessing() {
  connectionCheck();
  Schedulers.newThread().schedule(new Action1<Scheduler.Inner>() {
    @Override
    public void call(Inner t1) {
      process(getConnection().getCurrentFor(getChannel()));
    }
  });
}

代码示例来源：origin: com.github.mrstampy/esp

@Override
public void triggerProcessing(final int numSamples) {
  connectionCheck();
  Schedulers.newThread().schedule(new Action1<Scheduler.Inner>() {
    @Override
    public void call(Inner t1) {
      process(getConnection().getCurrentFor(numSamples, getChannel()));
    }
  });
}

代码示例来源：origin: com.netflix.schlep/schlep-core

@Override
  public void call() {
    try {
      observer.onNext(args);
      return;
    }
    catch (Throwable t) {
      System.out.println(t.getMessage());
      long delay = policy.getDelay(ctx);
      if (delay == -1) {
        observer.onError(t);
      }
      
      scheduler.schedule(this, delay, TimeUnit.MILLISECONDS);
    }
  }
}.call();