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

ReactiveSeq.takeWhile介绍

暂无

代码示例

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

@Override
public SortedSet<T> subSet(T fromElement, T toElement) {
 ReactiveSeq<T> x = host.stream()
             .dropWhile(e -> !Objects.equals(e, fromElement))
             .takeWhile(e -> !Objects.equals(e, toElement));
 return x.collect(Collectors.toCollection(()->new TreeSet<>(comparator())));
}

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

@Override
public final ReactiveSeq<T> cycleUntil(final Predicate<? super T> predicate) {
  return createSeq(Streams.cycle(unwrapStream()), reversible)
      .takeWhile(predicate.negate());
}

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

@Override
public final ReactiveSeq<T> cycleWhile(final Predicate<? super T> predicate) {
  return createSeq(Streams.cycle(unwrapStream()), reversible)
      .takeWhile(predicate);
}

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

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

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

@Test
public void testLimitWhile() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertEquals(asList(), s.get().takeWhile(i -> false).toList());
  assertTrue( s.get().takeWhile(i -> i < 3).toList().size()!=5);
  assertTrue(s.get().takeWhile(i -> true).toList().containsAll(asList(1, 2, 3, 4, 5)));
}
@Test

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

@Test
  public void testLimitWhile() {
    Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
    assertEquals(asList(), s.get().takeWhile(i -> false).toList());
    assertTrue( s.get().takeWhile(i -> i < 3).toList().size()!=5);
    assertTrue(s.get().takeWhile(i -> true).toList().containsAll(asList(1, 2, 3, 4, 5)));
  }

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

@Test
public void testLimitWhile() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertEquals(asList(), s.get().takeWhile(i -> false).toList());
  assertTrue( s.get().takeWhile(i -> i < 3).toList().size()!=5);
  assertTrue(s.get().takeWhile(i -> true).toList().containsAll(asList(1, 2, 3, 4, 5)));
}

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

@Test
public void testLimitWhile() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertEquals(asList(), s.get().takeWhile(i -> false).toList());
  assertTrue( s.get().takeWhile(i -> i < 3).toList().size()!=5);
  assertTrue(s.get().takeWhile(i -> true).toList().containsAll(asList(1, 2, 3, 4, 5)));
}

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

@Test
public void limitWhileTest(){
  List<Integer> list = new ArrayList<>();
  while(list.size()==0){
    list = of(1,2,3,4,5,6).takeWhile(it -> it<4)
          .peek(it -> System.out.println(it)).collect(Collectors.toList());
  }
  assertThat(Arrays.asList(1,2,3,4,5,6),hasItem(list.get(0)));
}

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

@Test
public void limitWhileTest(){
  List<Integer> list = new ArrayList<>();
  while(list.size()==0){
    list = of(1,2,3,4,5,6).takeWhile(it -> it<4)
          .peek(it -> System.out.println(it)).collect(Collectors.toList());
  }
  assertThat(Arrays.asList(1,2,3,4,5,6),hasItem(list.get(0)));
}

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

@Test
public void limitWhileTest(){
  List<Integer> list = new ArrayList<>();
  while(list.size()==0){
    list = of(1,2,3,4,5,6).takeWhile(it -> it<4)
          .peek(it -> System.out.println(it)).collect(Collectors.toList());
  }
  assertThat(Arrays.asList(1,2,3,4,5,6),hasItem(list.get(0)));
}

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

@Test
public void limitWhileTest(){
  List<Integer> list = new ArrayList<>();
  while(list.size()==0){
    list = of(1,2,3,4,5,6).takeWhile(it -> it<4)
          .peek(it -> System.out.println(it)).collect(Collectors.toList());
  }
  assertThat(Arrays.asList(1,2,3,4,5,6),hasItem(list.get(0)));
}

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

@Test
public void limitWhileTest(){
  List<Integer> list = new ArrayList<>();
  while(list.size()==0){
    list = of(1,2,3,4,5,6).takeWhile(it -> it<4)
          .peek(it -> System.out.println(it)).collect(Collectors.toList());
  }
  assertThat(Arrays.asList(1,2,3,4,5,6),hasItem(list.get(0)));
}

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

default  ReactiveSeq<E> stream(E e){
  return ReactiveSeq.range(fromEnum(e),Integer.MAX_VALUE).map(this::toEnum)
      .takeWhile(Option::isPresent)
        .filter(Option::isPresent).flatMap(Option::stream);
}

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

@Override
public Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> splitBy(final Predicate<T> splitter) {
  final Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> Tuple2 = duplicate();
  return Tuple.tuple(
      Tuple2._1().takeWhile(splitter), Tuple2._2().dropWhile(splitter));
}

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

@Override
public Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> splitBy(final Predicate<T> splitter) {
  final Tuple2<ReactiveSeq<T>, ReactiveSeq<T>> Tuple2 = duplicate();
  return Tuple.tuple(
      Tuple2._1().takeWhile(splitter), Tuple2._2().dropWhile(splitter));
}

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

@Test
public void takeWhileTest() {
  List<Integer> list = of(1, 2, 3, 4, 5, 6).takeWhile(it -> it < 4).peek(it -> System.out.println(it)).collect(Collectors.toList());
  System.out.println("List " + list);
  assertThat(list, hasItem(1));
  assertThat(list, hasItem(2));
  assertThat(list, hasItem(3));
}
@Test

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

default  ReactiveSeq<E> streamTo(E e,E end){
  return ReactiveSeq.range(fromEnum(e),fromEnum(end)).map(this::toEnum)
      .takeWhile(Option::isPresent)
      .filter(Option::isPresent).flatMap(Option::stream);
}

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

default  ReactiveSeq<E> streamThenTo(E e,E next,E end){
  int start=  fromEnum(e);
  int step = fromEnum(next)-start;
  return ReactiveSeq.range(start,step,fromEnum(end)).map(this::toEnum)
      .takeWhile(Option::isPresent)
      .filter(Option::isPresent).flatMap(Option::stream);
}

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

public LazySeq<LazySeq<T>> levels() {
  ReactiveSeq<LazySeq<T>> res = ReactiveSeq.iterate(LazySeq.of(this), sf -> sf.flatMap(a -> a.subForest()))
                       .takeWhile(l -> !l.isEmpty())
                       .map(xs -> xs.map(x -> x.head));
  return LazySeq.fromStream(res);
}