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

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

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

ReactiveSeq.takeUntil介绍

暂无

代码示例

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

default ReactiveSeq<T> streamUntil(Predicate<? super T> p){
  return ReactiveSeq.generate(this).takeUntil(p);
}
default ReactiveSeq<T> streamUntil(long time,TimeUnit unit){

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

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

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

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

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

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

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

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

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

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

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

@Test(expected = NullPointerException.class)
public void testLimitUntilWithNulls() {
  System.out.println(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList());
  assertTrue(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}

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

@Test
public void testLimitUntilWithNulls() {
  System.out.println(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList());
  assertTrue(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}

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

@Test
public void testLimitUntilWithNulls() {
  System.out.println(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList());
  assertTrue(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}

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

@Test
public void testLimitUntilWithNulls() {
  System.out.println(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList());
  assertTrue(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, null, 3, 4, 5)));
}

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntilWithNulls() {
  assertThat(of(1, 2, null, 3, 4, 5).takeUntil(i -> false).toList(), equalTo(asList(1, 2, null, 3, 4, 5)));
}
@Test

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntil() {
  assertTrue(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList().containsAll(asList(1, 2, 3, 4, 5)));
  assertFalse(of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList().size()==5);
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntil() {
  assertEquals(asList(1, 2, 3, 4, 5), of(1, 2, 3, 4, 5).takeUntil(i -> false).toList());
  assertEquals(asList(1, 2), of(1, 2, 3, 4, 5).takeUntil(i -> i % 3 == 0).toList());
  assertEquals(asList(1, 2), of(1, 2, 3, 4, 5).takeUntil(i -> i == 3).toList());
  assertEquals(asList(1, 2, 3), of(1, 2, 3, 4, 5).takeUntil(i -> i == 4).toList());
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
  assertEquals(asList(), of(1, 2, 3, 4, 5).takeUntil(i -> true).toList());
}

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

@Test
public void testLimitUntilWithNulls() {
  assertThat(of(1, 2, 3, 4, 5).takeUntil(i -> false).toList(), equalTo(asList(1, 2,3, 4, 5)));
}
@Test

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

@Test
public void takeUntil() {
  assertThat(of(1, 2, 3, 4, 5).takeUntil(p -> p == 2).toList().size(), greaterThan(0));
}

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法