本文整理了Java中cyclops.reactive.ReactiveSeq.filterNot
方法的一些代码示例,展示了ReactiveSeq.filterNot
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.filterNot
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称:ReactiveSeq
方法名:filterNot
暂无
代码示例来源:origin: aol/cyclops
default boolean allMatch(Predicate<? super Tuple2<K,V>> c){
return !stream().filterNot(c)
.findFirst()
.isPresent();
}
default boolean equalTo(PersistentMap<K,V> map){
代码示例来源:origin: aol/cyclops
/**
* True if predicate matches all elements when Monad converted to a Stream
*
* <pre>
* {@code
* assertThat(ReactiveSeq.of(1,2,3,4,5).allMatch(it-> it>0 && it <6),equalTo(true));
* }
* </pre>
*
* @param c
* Predicate to check if all match
*/
default boolean allMatch(final Predicate<? super T> c) {
return !stream().filterNot(c)
.findFirst()
.isPresent();
}
代码示例来源:origin: aol/cyclops
/**
* Turn a toX of Iors into a single Ior with Lists of values.
*
* <pre>
* {@code
*
* Ior<String,Integer> just = Ior.right(10);
Ior<String,Integer> none = Ior.left("none");
* Ior<String,ReactiveSeq<Integer>> iors =Ior.sequenceRight(Seq.of(just,none,Ior.right(1)));
//Ior.right(Seq.of(10,1)));
*
* }</pre>
*
*
*
* @param iors Iors to sequence
* @return Ior Sequenced
*/
public static <ST, PT> Ior<ST, ReactiveSeq<PT>> sequenceRight(final Iterable<Ior<ST, PT>> iors) {
return sequence(ReactiveSeq.fromIterable(iors).filterNot(Ior::isLeft));
}
public static <L,T> Ior<L,ReactiveSeq<T>> sequence(ReactiveSeq<? extends Ior<L,T>> stream) {
代码示例来源:origin: aol/cyclops
/**
* Turn a toX of Iors into a single Ior with Lists of values.
* Primary and left types are swapped during this operation.
*
* <pre>
* {@code
* Ior<String,Integer> just = Ior.right(10);
Ior<String,Integer> none = Ior.left("none");
* Ior<Seq<Integer>,Seq<String>> iors =Ior.sequenceLeft(Seq.of(just,none,Ior.right(1)));
//Ior.right(Seq.of("none")))
*
* }
* </pre>
*
*
* @param iors Iors to sequence
* @return Ior sequenced and swapped
*/
public static <ST, PT> Ior<PT, ReactiveSeq<ST>> sequenceLeft(final Iterable<? extends Ior<ST, PT>> iors) {
return sequence(ReactiveSeq.fromIterable(iors).filterNot(Ior::isRight).map(Ior::swap));
}
代码示例来源:origin: com.oath.cyclops/cyclops-futurestream
@Override
default FutureStream<U> filterNot(final Predicate<? super U> fn) {
return (FutureStream<U>) ReactiveSeq.super.filterNot(fn);
}
@Override
代码示例来源:origin: com.oath.cyclops/cyclops
default boolean allMatch(Predicate<? super Tuple2<K,V>> c){
return !stream().filterNot(c)
.findFirst()
.isPresent();
}
default boolean equalTo(PersistentMap<K,V> map){
代码示例来源:origin: com.oath.cyclops/cyclops
/**
* True if predicate matches all elements when Monad converted to a Stream
*
* <pre>
* {@code
* assertThat(ReactiveSeq.of(1,2,3,4,5).allMatch(it-> it>0 && it <6),equalTo(true));
* }
* </pre>
*
* @param c
* Predicate to check if all match
*/
default boolean allMatch(final Predicate<? super T> c) {
return !stream().filterNot(c)
.findFirst()
.isPresent();
}
代码示例来源:origin: com.oath.cyclops/cyclops
/**
* Turn a toX of Iors into a single Ior with Lists of values.
*
* <pre>
* {@code
*
* Ior<String,Integer> just = Ior.right(10);
Ior<String,Integer> none = Ior.left("none");
* Ior<String,ReactiveSeq<Integer>> iors =Ior.sequenceRight(Seq.of(just,none,Ior.right(1)));
//Ior.right(Seq.of(10,1)));
*
* }</pre>
*
*
*
* @param iors Iors to sequence
* @return Ior Sequenced
*/
public static <ST, PT> Ior<ST, ReactiveSeq<PT>> sequenceRight(final Iterable<Ior<ST, PT>> iors) {
return sequence(ReactiveSeq.fromIterable(iors).filterNot(Ior::isLeft));
}
public static <L,T> Ior<L,ReactiveSeq<T>> sequence(ReactiveSeq<? extends Ior<L,T>> stream) {
代码示例来源:origin: com.oath.cyclops/cyclops
/**
* Turn a toX of Iors into a single Ior with Lists of values.
* Primary and left types are swapped during this operation.
*
* <pre>
* {@code
* Ior<String,Integer> just = Ior.right(10);
Ior<String,Integer> none = Ior.left("none");
* Ior<Seq<Integer>,Seq<String>> iors =Ior.sequenceLeft(Seq.of(just,none,Ior.right(1)));
//Ior.right(Seq.of("none")))
*
* }
* </pre>
*
*
* @param iors Iors to sequence
* @return Ior sequenced and swapped
*/
public static <ST, PT> Ior<PT, ReactiveSeq<ST>> sequenceLeft(final Iterable<? extends Ior<ST, PT>> iors) {
return sequence(ReactiveSeq.fromIterable(iors).filterNot(Ior::isRight).map(Ior::swap));
}
内容来源于网络,如有侵权,请联系作者删除!