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

ReactiveSeq.groupedUntil介绍

[英]Create a ReactiveSeq batched by List, where each batch is populated until the predicate holds

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

[中]创建一个ReactiveSeq batched by List，其中每个批都被填充，直到谓词保持

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

代码示例

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

@Override
default <C extends PersistentCollection<? super T>> ImmutableQueue<C> groupedUntil(Predicate<? super T> predicate, Supplier<C> factory) {
  return unitStream(stream().groupedUntil(predicate,factory));
}

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

@Override
default ImmutableSortedSet<Vector<T>> groupedUntil(BiPredicate<Vector<? super T>, ? super T> predicate) {
  return unitStream(stream().groupedUntil(predicate));
}

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

@Override
default ImmutableList<Vector<T>> groupedUntil(BiPredicate<Vector<? super T>, ? super T> predicate) {
  return unitStream(stream().groupedUntil(predicate));
}

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

@Test
public void batchUntil(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntil(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntil(){
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void windowUntilEmpty(){
  assertThat(Spouts.<Integer>of()
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(0));
}
@Test

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

@Test
public void batchUntil(){
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Seq.of(1,2,3)));
}
@Test

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

@Test
public void windowUntilEmpty(){
  assertThat(ReactiveSeq.<Integer>of()
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(0));
}
@Test

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

@Test
public void batchUntil(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void windowUntil(){
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Seq.of(1,2,3)));
}
@Test

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

@Test
public void windowUntil(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .toList().get(0),equalTo(Seq.of(1,2,3)));
}
@Test

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

@Test
public void windowUntilEmpty(){
  assertThat(ReactiveSeq.<Integer>of()
      .groupedUntil(i->i%3==0)
      .toList().size(),equalTo(0));
}

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

@Test
public void windowStatefullyUntil(){
  System.out.println(of(1,2,3,4,5,6)
      .groupedUntil((s, i)->s.containsValue(4) ? true : false)
      .toList());
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil((s, i)->s.containsValue(4) ? true : false)
      .toList().size(),equalTo(2));
}
@Test

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

@Test
public void windowStatefullyUntilEmpty(){
  assertThat(of()
      .groupedUntil((s, i)->s.contains(4) ? true : false)
      .toList().size(),equalTo(0));
}
@Test

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

@Test
public void batchUntil(){
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .to(Streamable::fromStream).toList().size(),equalTo(2));
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0)
      .to(Streamable::fromStream).toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntilCollection(){
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()-> Vector.empty())
      .toList().size(),equalTo(2));
  assertThat(ReactiveSeq.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()->Vector.empty())
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntilCollection(){
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()->Vector.empty())
      .toList().size(),equalTo(2));
  assertThat(Spouts.of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()->Vector.empty())
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntilCollection(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()-> Vector.empty())
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()->Vector.empty())
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test

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

@Test
public void batchUntilCollection(){
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()-> Vector.empty())
      .toList().size(),equalTo(2));
  assertThat(of(1,2,3,4,5,6)
      .groupedUntil(i->i%3==0,()->Vector.empty())
      .toList().get(0),equalTo(Vector.of(1,2,3)));
}
@Test