本文整理了Java中cyclops.reactive.ReactiveSeq.takeUntil
方法的一些代码示例,展示了ReactiveSeq.takeUntil
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.takeUntil
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称: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));
}
内容来源于网络,如有侵权,请联系作者删除!