cyclops.reactive.ReactiveSeq.cycle()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(92)

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

ReactiveSeq.cycle介绍

[英]Convert to a Stream with the result of a reduction operation repeated specified times

List list = ReactiveSeq.of(1,2,2))

[中]将还原操作重复指定次数的结果转换为流

List list = ReactiveSeq.of(1,2,2))

代码示例

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

@Override
public ReactiveSeq<T> cycle() {
  ReactiveSeq<T> cycling = collectAll(Collectors.toList())
      .map(s -> Spouts.fromIterable(s).cycle(Long.MAX_VALUE))
      .flatMap(i -> i);
  return createSeq(new IterableSourceOperator<T>(cycling), SYNC);
}

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

@Test
public void iterateCycleStream(){
  for(int i=0;i<10000l;i++) {
    System.out.println("Next cycle " + i);
    Iterator<Integer> it =  of(1).stream().cycle(2).iterator();//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 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 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 = Spouts.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 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 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 cycleIterate(){
  Iterator<Integer> it = ReactiveSeq.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 = 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 testCycleLong() {
  assertEquals(asList(1, 2, 1, 2, 1, 2), Streams.oneShotStream(Stream.of(1, 2)).cycle(3).toList());
  assertEquals(asList(1, 2, 3, 1, 2, 3), Streams.oneShotStream(Stream.of(1, 2,3)).cycle(2).toList());
}
@Test

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

@Test
public void testCycleLong() {
  assertEquals(asList(1, 2, 1, 2, 1, 2), Streams.oneShotStream(Stream.of(1, 2)).cycle(3).toList());
  assertEquals(asList(1, 2, 3, 1, 2, 3), Streams.oneShotStream(Stream.of(1, 2,3)).cycle(2).toList());
}
@Test

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

@Test
public void testCycleLong() {
  assertEquals(asList(1, 2, 1, 2, 1, 2), Streams.oneShotStream(Stream.of(1, 2)).cycle(3).toList());
  assertEquals(asList(1, 2, 3, 1, 2, 3), Streams.oneShotStream(Stream.of(1, 2,3)).cycle(2).toList());
}
@Test

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

@Test
public void testCycle() {
  assertEquals(asList(1, 2, 1, 2, 1, 2), of(1, 2).cycle().take(6).toList());
  assertEquals(asList(1, 2, 3, 1, 2, 3), of(1, 2, 3).cycle().take(6).toList());
}

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

@Test
public void testCycleAsync() {
  //  of(1, 2).collectStream(CyclopsCollectors.listX())
  //        .concatMap(i->i.cycle(3)).printOut();
  // of(1, 2).cycle().limit(6).forEach(n->System.out.println("Next " + n));
  assertEquals(asList(1, 2, 1, 2, 1, 2),of(1, 2).cycle().limit(6).toList());
  assertEquals(asList(1, 2, 3, 1, 2, 3), of(1, 2, 3).cycle().limit(6).toList());
}
@Test

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

@Test
public void testCycle() {
    assertEquals(asList(1, 1, 1, 1, 1,1),of(1).cycle().limit(6).toList());
}

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

@Test
  public void multicastCycle(){
    final Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> t = of(1,2,3,4,5,6,7,8).duplicate();

//        t.v1.forEach(e->System.out.println("First " + e));
    //       t.v2.printOut();

    assertThat(t._1().limit(1).toList(),equalTo(Arrays.asList(1)));
    System.out.println("Second!");
    assertThat(t._2().cycle().limit(1).toList(),equalTo(Arrays.asList(1)));

  }
  @Test

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

@Test
  public void multicastCycle(){
    final Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> t = of(1,2,3,4,5,6,7,8).duplicate();

//        t.v1.forEach(e->System.out.println("First " + e));
    //       t.v2.printOut();

    assertThat(t._1().limit(1).toList(),equalTo(Arrays.asList(1)));
    System.out.println("Second!");
    assertThat(t._2().cycle().limit(1).toList(),equalTo(Arrays.asList(1)));

  }
}

内容来源于网络，如有侵权，请联系作者删除！

ReactiveSeq

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ReactiveSeq类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com