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

ReactiveSeq.groupedBySizeAndTime介绍

[英]Batch elements by size into a List

ReactiveSeq.of(1,2,3,4,5,6)

[中]按大小将元素批处理到列表中

ReactiveSeq.of(1,2,3,4,5,6)

代码示例

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

@Test
public void batchBySizeAndTimeTimeCollection(){
  for(int i=0;i<10;i++){
    System.out.println(i);
    List<Vector<Integer>> list = of(1,2,3,4,5,6)
        .groupedBySizeAndTime(10,1,TimeUnit.MICROSECONDS,()->Vector.empty())
        .toList();
    assertThat(list
            .get(0)
            ,not(hasItem(6)));
  }
}
@Test

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

@Test
public void windowBySizeAndTimeSizeEmpty(){
  assertThat(of()
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
          .toList()
          .size(),is(0));
}
@Test

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

@Test
public void batchBySizeAndTimeSize(){
  of(1,2,3,4,5,6)
  .groupedBySizeAndTime(3,10,TimeUnit.SECONDS).collect(Collectors.toList());
  List l = of(1,2,3,4,5,6)
      .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
      .toList();
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
          .toList().get(0)
          .size(),is(3));
}

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

@Test
public void windowBySizeAndTimeSizeEmpty(){
  assertThat(of()
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
          .toList()
          .size(),is(0));
}
@Test

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

@Test
public void windowBySizeAndTimeSizeEmpty(){
  assertThat(of()
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
          .toList()
          .size(),is(0));
}
@Test

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

@Test
public void windowBySizeAndTimeTime(){
  for(int i=0;i<10;i++){
    System.out.println(i);
    List<Vector<Integer>> list = of(1,2,3,4,5,6)
        .map(n-> n==6? sleep(1) : n)
        .groupedBySizeAndTime(10,1,TimeUnit.MICROSECONDS)
        .toList();
    assertThat(list
            .get(0)
            ,not(hasItem(6)));
  }
}

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

@Test
public void windowBySizeAndTimeSizeEmpty(){
  assertThat(of()
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS)
          .to(Streamable::fromStream).toList()
          .size(),is(0));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollection(){
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3, 10, TimeUnit.SECONDS, () -> Vector.empty())
          .toList().get(0)
          .size(),is(3));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollection(){
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3, 10, TimeUnit.SECONDS, () -> Vector.empty())
          .toList().get(0)
          .size(),is(3));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollection(){
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3, 10, TimeUnit.SECONDS, () -> Vector.empty())
          .toList().get(0)
          .size(),is(3));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollection(){
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3,10,TimeUnit.SECONDS,()->Vector.empty())
          .toList().get(0)
          .size(),is(3));
}
@Test

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

@Test
public void batchBySizeAndTimeSizeCollection(){
  assertThat(of(1,2,3,4,5,6)
          .groupedBySizeAndTime(3, 10, TimeUnit.SECONDS, () -> Vector.empty())
          .toList().get(0)
          .size(),is(3));
}
@Test

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

@Override
public Publisher<Long> createPublisher(long elements) {
  return Spouts.iterate(0l, i->i+1l)
         .groupedBySizeAndTime(1,1, TimeUnit.SECONDS)
         .map(l->l.getOrElse(0,-1l))
         .limit(elements);
}

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

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