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

ReactiveSeq.iterate介绍

暂无

代码示例

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

/**
 * @see Stream#iterate(Object, UnaryOperator)
 */
static <T> Streamable<T> iterate(final T seed, final UnaryOperator<T> f) {
  Objects.requireNonNull(f);
  return fromStream(ReactiveSeq.iterate(seed, f));
}

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

static <T> LazySeq<T> iterate(final T seed, Predicate<? super T> pred, final UnaryOperator<T> f) {
  return fromStream(ReactiveSeq.iterate(seed,pred,f));
}
static <T> LazySeq<T> iterate(final T seed, final UnaryOperator<T> f,long times) {

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

/**
 * Use the value stored in this Value to seed a Stream generated from the provided function
 *
 * @param fn Function to generate a Stream
 * @return Stream generated from a seed value (the Value stored in this Value) and the provided function
 */
default ReactiveSeq<R> iterate(final UnaryOperator<R> fn) {
  return ReactiveSeq.iterate(get(), fn);
}

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

public static <T> HashSet<T> iterate(final T seed, Predicate<? super T> pred, final UnaryOperator<T> f) {
  return fromStream(ReactiveSeq.iterate(seed,pred,f));
}
public static <T> HashSet<T> iterate(final T seed, final UnaryOperator<T> f,int max) {

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

static <T> TrieSet<T> iterate(final T seed, Predicate<? super T> pred, final UnaryOperator<T> f) {
  return fromStream(ReactiveSeq.iterate(seed,pred,f));
}
static <T> TrieSet<T> iterate(final T seed, final UnaryOperator<T> f,int max) {

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

public static <T> DifferenceList<T> iterate(final T seed, final UnaryOperator<T> f,long times) {
  return fromStream(ReactiveSeq.iterate(seed,f).limit(times));
}
public static <T> DifferenceList<T> iterate(final T seed, Predicate<? super T> pred, final UnaryOperator<T> f) {

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

@Override
public ReactiveSeq<T> stream() {
  return ReactiveSeq.iterate(0, i->i+1)
           .take(array.length)
           .map(indx->array[indx])
           .flatMap(a->{
             return ReactiveSeq.iterate(0, i->i+1)
                      .take(a.length)
                      .map(indx->a[indx])
                      .flatMap(a2-> ReactiveSeq.of((T[])a2));
           });
}

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

@Test
public void iteratePred(){
  assertThat(ReactiveSeq.iterate(0,i->i<10,i->i+1)
        .toList().size(),equalTo(10));
}
@Test

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

@Test
public void dynamic(){
  for(int i=0;i<100;i++) {
    Two<Integer> two = create(i, i);
    Two<Integer> mapped = two.map(n -> n * 100);
    System.out.println(Arrays.deepToString(two.array));
    System.out.println(Arrays.deepToString(mapped.array));
    assertThat(ReactiveSeq.fromIterator(mapped.iterator()).toList(),
      equalTo(ReactiveSeq.iterate(0,n->n+100).take(i*i).toList()));
  }
}

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

@Test
public void dynamic(){
  for(int i=0;i<20;i++) {
    Five<Integer> two = create(i, i,i,i,i);
    Five<Integer> mapped = two.map(n -> n * 100);
    System.out.println(Arrays.deepToString(two.array));
    System.out.println(Arrays.deepToString(mapped.array));
    assertThat(ReactiveSeq.fromIterator(mapped.iterator()).toList(),
      equalTo(ReactiveSeq.iterate(0,n->n+100).take(i*i*i*i*i).toList()));
  }
}

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

@Test
public void dynamic(){
  for(int i=0;i<20;i++) {
    Four<Integer> two = create(i, i,i,i);
    Four<Integer> mapped = two.map(n -> n * 100);
    System.out.println(Arrays.deepToString(two.array));
    System.out.println(Arrays.deepToString(mapped.array));
    assertThat(ReactiveSeq.fromIterator(mapped.iterator()).toList(),
      equalTo(ReactiveSeq.iterate(0,n->n+100).take(i*i*i*i).toList()));
  }
}

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

@Test
public void dynamic(){
  for(int i=0;i<10;i++) {
    Six<Integer> two = create(i, i,i,i,i,i);
    Six<Integer> mapped = two.map(n -> n * 100);
   //  System.out.println(Arrays.deepToString(two.array));
    System.out.println(Arrays.deepToString(mapped.array));
    assertThat(mapped.stream().toList(),
      equalTo(ReactiveSeq.iterate(0,n->n+100).take(i*i*i*i*i*i).toList()));
  }
}

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

public LazySeq<LazySeq<T>> levels() {
  ReactiveSeq<LazySeq<T>> res = ReactiveSeq.iterate(LazySeq.of(this), sf -> sf.flatMap(a -> a.subForest()))
                       .takeWhile(l -> !l.isEmpty())
                       .map(xs -> xs.map(x -> x.head));
  return LazySeq.fromStream(res);
}

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

@Test
public void groupedInfinite() {
  ReactiveSeq<Integer> infinite = ReactiveSeq.iterate(1, i->i+1);
  final ReactiveSeq<Vector<Integer>> grouped = infinite.grouped(3);
  assertThat(grouped.elementAt(0).toOptional().get(),equalTo(Vector.of(1,2,3)));
}

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

@Test
public void groupedInfinite() {
  ReactiveSeq<Integer> infinite = ReactiveSeq.iterate(1, i->i+1);
  final ReactiveSeq<Vector<Integer>> grouped = infinite.grouped(3);
  assertThat(grouped.elementAt(0).toOptional().get(),equalTo(Vector.of(1,2,3)));
}

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

@Test
public void batchByTimex() {
      iterate("", last -> "next")
      .limit(100)
      .peek(next->System.out.println("Counter " +count2.incrementAndGet()))
      .groupedByTime(10, TimeUnit.MICROSECONDS)
      .peek(batch -> System.out.println("batched : " + batch))
      .filter(c->!c.isEmpty())
      .forEach(System.out::println);
}

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

@Test
public void batchBySize() {
  iterate("", last -> "next")
      .limit(100)
      .grouped(10)
      .onePer(1, TimeUnit.MICROSECONDS)
      .peek(batch -> System.out.println("batched : " + batch))
      .concatMap(Function.identity())
      .peek(individual -> System.out.println("Flattened : "
          + individual))
      .forEach(a->{});
}

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

@Test
public void onePerSecond() {
  long start = System.currentTimeMillis();
      iterate(0, it -> it + 1)
      .limit(3)
      .onePer(1, TimeUnit.SECONDS)
      .map(seconds -> "hello!")
      .peek(System.out::println)
      .toList();
 assertTrue(System.currentTimeMillis()-start>1900);
}
@Test

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

@Override
public Publisher<Long> createPublisher(long elements) {
  return Spouts.fromSpliterator(ReactiveSeq.iterate(0l,i->i+1l).spliterator())
      .limit(elements)
      .filter(i->true);
}

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

@Test
public void iterate(){
  ReactiveSeq<Integer> s = ReactiveSeq.iterate(1,i->i+1);
  assertThat(s.limit(10).takeRight(1).asFunction().apply(0l),equalTo(10));
  assertThat(s.limit(10).takeRight(1).asFunction().apply(0l),equalTo(10));
}