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

ReactiveSeq.unit介绍

暂无

代码示例

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

/**
 * Convert to a Stream with the result of a reduction operation repeated
 * specified times
 *
 * <pre>
 * {@code
 *   List<Integer> list = ReactiveSeq.of(1,2,2))
 *                                 .cycle(Reducers.toCountInt(),3)
 *                                 .collect(CyclopsCollectors.toList());
 *   //List[3,3,3];
 *   }
 * </pre>
 *
 * @param m
 *            Monoid to be used in reduction
 * @param times
 *            Number of times value should be repeated
 * @return Stream with reduced values repeated
 */
@Override
default ReactiveSeq<T> cycle(Monoid<T> m, long times){
  return unit(m.foldLeft(this)).cycle(times);
}

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

@Override
public <T> FutureStream<T> unit(final T unit) {
  return fromStream(stream().unit(unit));
}

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

/**
 * Convert to a Stream with the result of a reduction operation repeated
 * specified times
 *
 * <pre>
 * {@code
 *   List<Integer> list = ReactiveSeq.of(1,2,2))
 *                                 .cycle(Reducers.toCountInt(),3)
 *                                 .collect(CyclopsCollectors.toList());
 *   //List[3,3,3];
 *   }
 * </pre>
 *
 * @param m
 *            Monoid to be used in reduction
 * @param times
 *            Number of times value should be repeated
 * @return Stream with reduced values repeated
 */
@Override
default ReactiveSeq<T> cycle(Monoid<T> m, long times){
  return unit(m.foldLeft(this)).cycle(times);
}