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

ReactiveSeq.splitBy介绍

[英]Split stream at point where predicate no longer holds

ReactiveSeq.of(1, 2, 3, 4, 5, 6).splitBy(i->i

[中]在谓词不再保持的点拆分流

ReactiveSeq.of(1, 2, 3, 4, 5, 6).splitBy(i->i

代码示例

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

@Test
public void testSplitBy() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(6, s.get().splitBy(i -> i % 2 != 0)._1().toList().size() + s.get().splitBy(i -> i % 2 != 0)._2().toList().size());
  assertTrue(s.get().splitBy(i -> true)._1().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
  assertEquals(asList(), s.get().splitBy(i -> true)._2().toList());
  assertEquals(asList(), s.get().splitBy(i -> false)._1().toList());
  assertTrue(s.get().splitBy(i -> false)._2().toList().containsAll(asList(1, 2, 3, 4, 5, 6)));
}

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

/**
 * Split stream at point where predicate no longer holds
 * <pre>
 * {@code
 *   Streamable.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)
 *
 *   //Streamable[1,2,3] Streamable[4,5,6]
 * }
 * </pre>
 */
default Tuple2<Streamable<T>, Streamable<T>> splitBy(final Predicate<T> splitter) {
  return this.stream().splitBy(splitter)
            .map1(s -> fromStream(s))
            .map2(s -> fromStream(s));
}

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

@Test
public void splitBy(){
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void splitBy(){
  assertThat( Spouts.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( Spouts.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void splitBy(){
  assertThat( Spouts.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( Spouts.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void splitBy(){
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void splitBy(){
  assertThat( ReactiveSeq.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( ReactiveSeq.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void splitBy(){
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._1().toList(),equalTo(Arrays.asList(1,2,3)));
  assertThat( of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)._2().toList(),equalTo(Arrays.asList(4,5,6)));
}
@Test

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

@Test
public void testPartition() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5, 6);
  assertEquals(asList(1, 3, 5), s.get().partition(i -> i % 2 != 0)._1().toList());
  assertEquals(asList(2, 4, 6), s.get().partition(i -> i % 2 != 0)._2().toList());
  assertEquals(asList(2, 4, 6), s.get().partition(i -> i % 2 == 0)._1().toList());
  assertEquals(asList(1, 3, 5), s.get().partition(i -> i % 2 == 0)._2().toList());
  assertEquals(asList(1, 2, 3), s.get().partition(i -> i <= 3)._1().toList());
  assertEquals(asList(4, 5, 6), s.get().partition(i -> i <= 3)._2().toList());
  assertEquals(asList(1, 2, 3, 4, 5, 6), s.get().partition(i -> true)._1().toList());
  assertEquals(asList(), s.get().partition(i -> true)._2().toList());
  assertEquals(asList(), s.get().partition(i -> false)._1().toList());
  assertEquals(asList(1, 2, 3, 4, 5, 6), s.get().splitBy(i -> false)._2().toList());
}

代码示例来源：origin: com.oath.cyclops/cyclops-futurestream

@Override
default Tuple2<ReactiveSeq<U>, ReactiveSeq<U>> splitBy(final Predicate<U> splitter) {
  return ReactiveSeq.oneShotStream(stream())
           .splitBy(splitter);
}

代码示例来源：origin: com.oath.cyclops/cyclops

/**
 * Split stream at point where predicate no longer holds
 * <pre>
 * {@code
 *   Streamable.of(1, 2, 3, 4, 5, 6).splitBy(i->i<4)
 *
 *   //Streamable[1,2,3] Streamable[4,5,6]
 * }
 * </pre>
 */
default Tuple2<Streamable<T>, Streamable<T>> splitBy(final Predicate<T> splitter) {
  return this.stream().splitBy(splitter)
            .map1(s -> fromStream(s))
            .map2(s -> fromStream(s));
}