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

ReactiveSeq.fixedDelay介绍

[英]emit elements after a fixed delay

SimpleTimer timer = new SimpleTimer();

[中]在固定延迟后发射元素

SimpleTimer timer = new SimpleTimer();

代码示例

代码示例来源：origin: aol/cyclops

/**
 * emit elements after a fixed delay
 * <pre>
 * {@code
 *     SimpleTimer timer = new SimpleTimer();
  assertThat(Streamable.of(1,2,3,4,5,6)
            .fixedDelay(10000,TimeUnit.NANOSECONDS)
            .collect(CyclopsCollectors.toList())
            .size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
 * }
 * </pre>
 * @param l time length in nanos of the delay
 * @param unit for the delay
 * @return Streamable that emits each element after a fixed delay
 */
default ReactiveSeq<T> fixedDelay(final long l, final TimeUnit unit) {
  return this.stream().fixedDelay(l, unit);
}

代码示例来源：origin: aol/cyclops

/**
   * emit elements after a fixed delay
   *
   * <pre>
   * {@code
   *  SimpleTimer timer = new SimpleTimer();
   *  ReactiveSeq.of(1, 2, 3, 4, 5, 6)
   *             .fixedDelay(10000, TimeUnit.NANOSECONDS)
   *             .collect(CyclopsCollectors.toList())
   *             .size()
   *  //6
   *  //timer.getElapsedNanoseconds() > greaterThan(60000l)
   * }
   * </pre>
   *
   * @param l
   *            time length in nanos of the delay
   * @param unit
   *            for the delay
   * @return ReactiveSeq that emits each element after a fixed delay
   */
  default ReactiveSeq<T> fixedDelay(final long l, final TimeUnit unit) {
    return stream().fixedDelay(l, unit);
  }
}

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  fromIntStream(IntStream.range(0, 1000))
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  fromIntStream(IntStream.range(0, 1000))
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay(){
  SimpleTimer timer = new SimpleTimer();
  assertThat(of(1,2,3,4,5,6).fixedDelay(10000,TimeUnit.NANOSECONDS).to(Streamable::fromStream).collect(Collectors.toList()).size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  Spouts.range(0, 1000)
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  Spouts.range(0, 1000)
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  Spouts.range(0, 1000)
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  Spouts.range(0, 1000)
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void fixedDelay2() {
  Spouts.range(0, 1000)
      .fixedDelay(1l, TimeUnit.MICROSECONDS).peek(System.out::println)
      .forEach(a->{});
}
@Test

代码示例来源：origin: com.oath.cyclops/cyclops

/**
 * emit elements after a fixed delay
 * <pre>
 * {@code
 *     SimpleTimer timer = new SimpleTimer();
  assertThat(Streamable.of(1,2,3,4,5,6)
            .fixedDelay(10000,TimeUnit.NANOSECONDS)
            .collect(CyclopsCollectors.toList())
            .size(),is(6));
  assertThat(timer.getElapsedNanoseconds(),greaterThan(60000l));
 * }
 * </pre>
 * @param l time length in nanos of the delay
 * @param unit for the delay
 * @return Streamable that emits each element after a fixed delay
 */
default ReactiveSeq<T> fixedDelay(final long l, final TimeUnit unit) {
  return this.stream().fixedDelay(l, unit);
}

代码示例来源：origin: com.oath.cyclops/cyclops

/**
   * emit elements after a fixed delay
   *
   * <pre>
   * {@code
   *  SimpleTimer timer = new SimpleTimer();
   *  ReactiveSeq.of(1, 2, 3, 4, 5, 6)
   *             .fixedDelay(10000, TimeUnit.NANOSECONDS)
   *             .collect(CyclopsCollectors.toList())
   *             .size()
   *  //6
   *  //timer.getElapsedNanoseconds() > greaterThan(60000l)
   * }
   * </pre>
   *
   * @param l
   *            time length in nanos of the delay
   * @param unit
   *            for the delay
   * @return ReactiveSeq that emits each element after a fixed delay
   */
  default ReactiveSeq<T> fixedDelay(final long l, final TimeUnit unit) {
    return stream().fixedDelay(l, unit);
  }
}