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

ReactiveSeq.iterator介绍

暂无

代码示例

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

@Override
 public Iterator<Tuple2<K, V>> iterator() {
   return stream().iterator();
 }
@Override

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

@Override
  public Iterator<T> iterator() {
    return stream().iterator();
  }
}

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

@Override
default BankersQueue<T> prependAll(Iterable<? extends T> value){
    Iterator<? extends T> it = ReactiveSeq.fromIterable(value).reverse().iterator();
    BankersQueue<T> res= this;
    while(it.hasNext()){
      res = res.prepend(it.next());
    }
    return res;
}

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

@Test
public void array(){
  Iterator<Integer> it = Spouts.of(1, 2, 3).iterator();
  List<Integer> list = new ArrayList<>();
  while(it.hasNext()){
    list.add(it.next());
  }
  assertThat(list,equalTo(Arrays.asList(1,2,3)));
}
@Test

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

@Test
public void rangeLong(){
  Iterator<Long> it = Spouts.rangeLong(1,4).iterator();
  List<Long> list = new ArrayList<>();
  while(it.hasNext()){
    list.add(it.next());
  }
  assertThat(list,equalTo(Arrays.asList(1l,2l,3l)));
}

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

@Test
public void iterateStream(){
  Iterator<Integer> it = of(1,2,3).stream().iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2.size(),equalTo(3));
}
@Test

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

@Test
public void cycleIterateIterable(){
  Iterator<Integer> it = ReactiveSeq.fromIterable(Arrays.asList(1)).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,1)));
}
@Test

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

@Test
public void cycleIterateIterable(){
  Iterator<Integer> it = ReactiveSeq.fromIterable(Arrays.asList(1)).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,1)));
}
@Test

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

@Test
public void cycleIterate(){
  Iterator<Integer> it = of(1).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,1)));
}
@Test

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

@Test
public void cycleIterate2(){
  Iterator<Integer> it = Spouts.of(1,2).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,2,1,2)));
}

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

@Test
public void cycleIterate2(){
  Iterator<Integer> it = of(1,2).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,2,1,2)));
}

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

@Test
public void cycleIterate2(){
  Iterator<Integer> it = ReactiveSeq.of(1,2).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,2,1,2)));
}

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

@Test
public void cycleIterate(){
  Iterator<Integer> it = of(1).stream().cycle(2).iterator();
  List<Integer> list2 = new ArrayList<>();
  while(it.hasNext())
    list2.add(it.next());
  assertThat(list2,equalTo(Arrays.asList(1,1)));
}
@Test

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

@Test
public void iterateFlatMapStream(){
  for(int i=0;i<100000l;i++) {
    System.out.println("Next cycle " + i);
    Iterator<Integer> it =  of(1).stream().concatMap(a->ReactiveSeq.of(a*2)).iterator();
    List<Integer> list2 = new ArrayList<>();
    while (it.hasNext())
      list2.add(it.next());
    assertThat(list2, equalTo(Arrays.asList(2)));
  }
}

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

@Test
public void fluxConcat(){
  Iterator<Integer> it = Spouts.from(Flux.concat(Flux.just(1, 2, 3), Flux.just(10, 20, 30))).iterator();
  while(it.hasNext()){
    System.out.println("next " + it.next());
  }
}
@Test

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

@Test
public void fluxMerge(){
  Iterator<Integer> it = Spouts.from(Flux.merge(Flux.just(1, 2, 3), Flux.just(10, 20, 30))).iterator();
  while(it.hasNext()){
    System.out.println("next " + it.next());
  }
}
@Test

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

@Test
public void publishAndSubscribeIterator(){
  assertThat(ReactiveSeq.fromIterator(Spouts.from(ReactiveSeq.of(1,2,3)).iterator()).toList(),equalTo(
      Arrays.asList(1,2,3)));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollectionIterator(){
  Iterator<Vector<Integer>> it = of(1, 2, 3, 4, 5, 6)
      .groupedBySizeAndTime(3, 10, TimeUnit.SECONDS, () -> Vector.empty()).iterator();
  assertThat(ReactiveSeq.fromIterator(it)
      .toList().get(0)
      .size(),is(3));
}
@Test

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

@Test
public void flatMapPubIteration(){
  Iterator<Integer> it = of(1,2,3,4)
      .mergeMap(i->of(5,6)
          .mergeMap(k->of(k)))
      .iterator();
  assertThat(ReactiveSeq.fromIterator(it).size(),equalTo(8));
}
@Test

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

@Test
public void slidingWithSmallWindowAtEndIterative() {
  Iterator<Seq<Integer>> it =  of(1, 2, 3, 4, 5).sliding(2,2).iterator();
  List<Seq<Integer>> sliding = ReactiveSeq.fromIterator(it).toList();
  assertThat(sliding, contains(Seq.of(1, 2), Seq.of(3, 4), Seq.of(5)));
}