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

ReactiveSeq.size介绍

[英][equivalent to count]
[中][相当于计数]

代码示例

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

/**
 * [equivalent to count]
 *
 * @return size
 */
default int size() {
  return this.stream().size();
}

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

@Test
public void atPercentile(){
  assertThat(stats.atPercentile(0),equalTo(Option.some(0)));
  assertThat(stats.atPercentile(1),equalTo(Option.some(1)));
  assertThat(stats.atPercentile(5),equalTo(Option.some(5)));
  assertThat(stats.size(),equalTo(100));
  assertThat(stats.atPercentile(99),equalTo(Option.some(99)));
}

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

@Test
public void atPercentile1000(){
  assertThat(stats1000.atPercentile(0),equalTo(Option.some(0)));
  assertThat(stats1000.atPercentile(1),equalTo(Option.some(10)));
  assertThat(stats1000.atPercentile(5),equalTo(Option.some(50)));
  assertThat(stats1000.atPercentile(5.5),equalTo(Option.some(55)));
  assertThat(stats1000.size(),equalTo(1000));
  assertThat(stats1000.atPercentile(99),equalTo(Option.some(990)));
}

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

@Test
public void stream() throws Exception {
  assertThat(diet.stream().size(),equalTo(18));
}

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

@Test
public void plusAllSize(){
  ReactiveSeq<Integer> vec = Spouts.empty();
  vec = vec.insertAt(Math.max(0,vec.size()),Spouts.of(1));
  System.out.println("Vec1 " + vec.vector());
  vec = vec.insertAt(Math.max(0,vec.size()),Spouts.of(2));
  // System.out.println("Vec " + vec.vector());
  /**Iterator<Integer> it = vec.iterator();
  while(it.hasNext()){
    System.out.println(it.next());
  }**/
  assertThat(vec,equalTo(Spouts.of(1,2)));
}
@Test

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

@Test
public void intOps(){
  assertThat(ReactiveSeq.range(1, 1000).ints(i->i,s->s.map(i->i*2).filter(i->i<500))
             .size(),equalTo(249));
}

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

@Test
public void doubles(){
  assertThat(ReactiveSeq.range(1, 1000).doubles(i->i.doubleValue(),s->s.map(i->i*2).filter(i->i<500))
             .size(),equalTo(249));
}
@Test

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

@Test
public void flatMap(){
  DIET<Integer> d2 = diet.flatMap(i -> DIET.cons(range(500, 1000)));
  List<Integer> l = d2.stream().toList();
  System.out.println(d2);
  System.out.println(range(500,1000).stream().size());
  assertThat(d2.stream().toList().size(),equalTo(501));
}

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

@Test
public void longs(){
  assertThat(ReactiveSeq.rangeLong(1, 1000).longs(i->i,s->s.map(i->i*2).filter(i->i<500))
             .size(),equalTo(249));
}

代码示例来源：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: com.oath.cyclops/cyclops

/**
 * [equivalent to count]
 *
 * @return size
 */
default int size() {
  return this.stream().size();
}