cyclops.reactive.ReactiveSeq.dropWhile()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(98)

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

ReactiveSeq.dropWhile介绍

暂无

代码示例

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

@Override
default ReactiveSeq<T> dropUntil(final Predicate<? super T> p) {
  return dropWhile(p.negate());
}

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

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

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

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

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

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

代码示例来源: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

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

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

@Override
default Streamable<T> dropWhile(final Predicate<? super T> p) {
  return Streamable.fromStream(this.stream().dropWhile(p));
}

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

@Override
default ImmutableQueue<T> dropWhile(Predicate<? super T> p) {
  return unitStream(stream().dropWhile(p));
}

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

@Override
default ImmutableSet<T> dropWhile(Predicate<? super T> p) {
  return unitStream(stream().dropWhile(p));
}

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

@Override
default ImmutableSortedSet<T> dropWhile(Predicate<? super T> p) {
  return unitStream(stream().dropWhile(p),comparator());
}

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

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

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

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

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

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

代码示例来源: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 testSkipWhileInclusive() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, 3, 4, 5);
  assertTrue(s.get().dropWhile(i -> false).toList().containsAll(asList(2, 3, 4, 5)));
  assertEquals(asList(), s.get().dropWhile(i -> true).toList());
}

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

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

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

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

代码示例来源: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(expected= NullPointerException.class)
public void testSkipWhilelWithNulls() {
  Supplier<ReactiveSeq<Integer>> s = () -> of(1, 2, null, 3, 4, 5);
  assertTrue(s.get().dropWhile(i -> true).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}
@Test(expected= NullPointerException.class)

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

@Test
public void dropWhileEmpty() {
  assertThat(of().dropWhile(p -> true).toList(), equalTo(Arrays.asList()));
}

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法