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

ReactiveSeq.onEmptyGet介绍

暂无

代码示例

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

@Override
default ReactiveSeq<T> onEmpty(T value){
  return onEmptyGet(()->value);
}

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

@Override
default Streamable<T> onEmptyGet(final Supplier<? extends T> supplier) {
  return fromStream(this.stream().onEmptyGet(supplier));
}

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

@Test
public void onEmptySwitchGet(){
  for(int i=0;i<ITERATIONS;i++){
  //for(int i=0;i<100_000;i++){
    System.out.println("Iteration " + i);
    assertThat(of()
            .onEmptyGet(() -> 1).mergeMap(a->ReactiveSeq.of(1))
            .toList(),
        equalTo(Arrays.asList(1)));
  }
}
@Test

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

@Override
default ReactiveSeq<T> onEmpty(T value){
  return onEmptyGet(()->value);
}

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

@Override
default Streamable<T> onEmptyGet(final Supplier<? extends T> supplier) {
  return fromStream(this.stream().onEmptyGet(supplier));
}

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

/**
 * Produce this stream, or an alternative stream from the
 * {@code supplier}, in case this stream is empty.
 *
 * <pre>
 * {@code
 *    FutureStream.of().onEmptyGet(() -> 1)
 *
 *
 *  //1
 * }
 * </pre>
 *
 */
@Override
default FutureStream<U> onEmptyGet(final Supplier<? extends U> supplier) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
                 .onEmptyGet(supplier));
}