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

ReactiveSeq.limit介绍

暂无

代码示例

代码示例来源：origin: aol/micro-server

public void schedule() {
  loader.forEach(dl -> {
    // run on startup
    create(dl).limit(1).foldFuture(executor, s -> s.forEach(Long.MAX_VALUE, l -> {}));
    // schedule
    create(dl).schedule(dl.getCron(), executor);
  });
}

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

@Test
public void flattenEmptyStream() throws Exception {
  assertThat(ReactiveSeq.<Integer>of(1,2,3,4,5,5,6,8,9,10).limit(10).collect(Collectors.toList()).size(),
                  equalTo(asList(2, 3, 4, 5, 6, 7, 0, 0, 0, 0).size()));
}

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

@Test
public void testLimit(){
  assertThat(of(1,2,3,4,5).limit(2).collect(Collectors.toList()).size(),equalTo(2));
}
@Test

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

@Test
public void rangeLong(){
  assertThat(ReactiveSeq.rangeLong(0,Long.MAX_VALUE)
      .limit(2).toList(),equalTo(Arrays.asList(0l,1l)));
}
@Test

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

@Test
public void testReverseListLimit() {
  assertThat( Spouts.fromIterable(Arrays.asList(10,400,2,-1)).limit(2)
          .reverse().toList(), equalTo(asList(400, 10)));
}
@Test

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

@Test
public void testReverseListLimitOneShot() {
  assertThat( ReactiveSeq.oneShotList(Arrays.asList(10,400,2,-1)).limit(2)
      .reverse().toList(), equalTo(asList(-1, 2)));
}
@Test

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

@Test
public void groupedWhile(){
  assertThat(Spouts.iterate(0l, i->i+1l)
      .groupedWhile(i->false)
      .map(l->l.get(0))
      .limit(100)
      .collect(Collectors.toList()).size(),equalTo(100));
}
@Test

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

@Test
public void testQuadriplicateLimit(){
   Tuple4<ReactiveSeq<Integer>, ReactiveSeq<Integer>, ReactiveSeq<Integer>,ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).quadruplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
   assertTrue(copies._3().limit(3).toList().size()==3);
   assertTrue(copies._4().limit(3).toList().size()==3);
}

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

@Test
public void testQuadriplicateLimit(){
   Tuple4<ReactiveSeq<Integer>, ReactiveSeq<Integer>, ReactiveSeq<Integer>,ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).quadruplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
   assertTrue(copies._3().limit(3).toList().size()==3);
   assertTrue(copies._4().limit(3).toList().size()==3);
}

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

@Test
public void negative(){
  assertThat(Spouts.range(-1000,Integer.MAX_VALUE)
      .limit(100)
      .count(),equalTo(100L));
}
@Test

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

@Test
public void rangeIntReversed(){
  assertThat(Spouts.range(0,10).reverse()
      .limit(2).toList(),equalTo(Arrays.asList(9, 8)));
}
@Test

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

@Test
public void take2Reversed(){
  assertThat(Spouts.range(0,10).reverse().limit(2).toList(),equalTo(Arrays.asList(9, 8)));
}
@Test

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

@Test
public void testTriplicateLimit(){
  Tuple3<ReactiveSeq<Integer>, ReactiveSeq<Integer>, ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).triplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
   assertTrue(copies._3().limit(3).toList().size()==3);
}
@Test

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

@Test
public void testDuplicateLimit(){
   Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).duplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
}
@Test

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

@Test
public void testDuplicateLimit(){
   Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).duplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
}
@Test

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

@Test
public void testDuplicateLimit(){
   Tuple2<ReactiveSeq<Integer>, ReactiveSeq<Integer>> copies =of(1,2,3,4,5,6).duplicate();
   assertTrue(copies._1().limit(3).toList().size()==3);
   assertTrue(copies._2().limit(3).toList().size()==3);
}
@Test

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

@Test
public void rangeIntReversedSkip(){
  assertThat(ReactiveSeq.range(0,Integer.MAX_VALUE).reverse()
      .limit(10).skip(8).toList(),equalTo(Arrays.asList(2147483638, 2147483637)));
}

代码示例来源：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 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 testUnzipWithLimits() {

    Supplier<ReactiveSeq<Tuple2<Integer, String>>> s = () -> ReactiveSeq.of(
        tuple(1, "a"),tuple(2, "b"),tuple(3, "c"));

    Tuple2<ReactiveSeq<Integer>, ReactiveSeq<String>> u1 = ReactiveSeq.unzip(s
        .get());

    assertTrue(u1._1().limit(2).toList().containsAll(Arrays.asList(1, 2)));

    assertTrue(u1._2().toList().containsAll(Arrays.asList("a", "b", "c")));

  }
}