本文整理了Java中cyclops.reactive.ReactiveSeq.deferFromStream
方法的一些代码示例,展示了ReactiveSeq.deferFromStream
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.deferFromStream
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称:ReactiveSeq
方法名:deferFromStream
暂无
代码示例来源:origin: aol/cyclops
default ReactiveSeq<Tuple2<T,Integer>> occurances(){
return ReactiveSeq.deferFromStream(() -> {
Map<T, Integer> map = stream().collect(Collectors.toMap(k -> k, v -> 1, (a, b) -> a + b));
return map.entrySet().stream();
}).map(e->Tuple.tuple(e.getKey(),e.getValue()));
}
代码示例来源:origin: aol/cyclops
default ReactiveSeq<T> insertAt(int pos, ReactiveSeq<? extends T> values){
if(pos==0){
return prependStream(values);
}
long check = new Long(pos);
boolean added[] = {false};
return ReactiveSeq.<T>concat(zipWithIndex().flatMap(t -> {
if (t._2() < check && !added[0])
return ReactiveSeq.of(t._1());
if (!added[0]) {
added[0]=true;
return ReactiveSeq.concat(values, ReactiveSeq.of(t._1()));
}
return Stream.of(t._1());
}), ReactiveSeq.deferFromStream(()-> {
return !added[0] ? values : ReactiveSeq.empty();
}
));
}
代码示例来源:origin: aol/cyclops
default ReactiveSeq<T> insertAt(int pos, Iterable<? extends T> values){
if(pos==0){
return prependStream(ReactiveSeq.fromIterable(values));
}
long check = new Long(pos);
boolean added[] = {false};
return ReactiveSeq.<T>concat(zipWithIndex().flatMap(t -> {
if (t._2() < check && !added[0])
return ReactiveSeq.of(t._1());
if (!added[0]) {
added[0] = true;
return ReactiveSeq.concat(ReactiveSeq.fromIterable(values), ReactiveSeq.of(t._1()));
}
return Stream.of(t._1());
}), ReactiveSeq.deferFromStream(()-> {
return !added[0] ? ReactiveSeq.fromIterable(values) : ReactiveSeq.empty();
}
));
}
default ReactiveSeq<T> insertAt(int pos, ReactiveSeq<? extends T> values){
代码示例来源:origin: aol/cyclops
}),ReactiveSeq.deferFromStream(()-> {
return !added[0] ? ReactiveSeq.of(values) : ReactiveSeq.empty();
代码示例来源:origin: com.oath.cyclops/cyclops-pure
@Override
public <T, R> Higher<reactiveSeq, R> tailRec(T initial, Function<? super T, ? extends Higher<reactiveSeq,? extends Either<T, R>>> fn) {
return Spouts.reactive(ReactiveSeq.deferFromStream( ()-> ReactiveSeq.tailRec(initial, fn.andThen(ReactiveSeq::narrowK))),ex);
}
};
代码示例来源:origin: com.oath.cyclops/cyclops
default ReactiveSeq<Tuple2<T,Integer>> occurances(){
return ReactiveSeq.deferFromStream(() -> {
Map<T, Integer> map = stream().collect(Collectors.toMap(k -> k, v -> 1, (a, b) -> a + b));
return map.entrySet().stream();
}).map(e->Tuple.tuple(e.getKey(),e.getValue()));
}
代码示例来源:origin: com.oath.cyclops/cyclops
default ReactiveSeq<T> insertAt(int pos, ReactiveSeq<? extends T> values){
if(pos==0){
return prependStream(values);
}
long check = new Long(pos);
boolean added[] = {false};
return ReactiveSeq.<T>concat(zipWithIndex().flatMap(t -> {
if (t._2() < check && !added[0])
return ReactiveSeq.of(t._1());
if (!added[0]) {
added[0]=true;
return ReactiveSeq.concat(values, ReactiveSeq.of(t._1()));
}
return Stream.of(t._1());
}), ReactiveSeq.deferFromStream(()-> {
return !added[0] ? values : ReactiveSeq.empty();
}
));
}
代码示例来源:origin: com.oath.cyclops/cyclops
default ReactiveSeq<T> insertAt(int pos, Iterable<? extends T> values){
if(pos==0){
return prependStream(ReactiveSeq.fromIterable(values));
}
long check = new Long(pos);
boolean added[] = {false};
return ReactiveSeq.<T>concat(zipWithIndex().flatMap(t -> {
if (t._2() < check && !added[0])
return ReactiveSeq.of(t._1());
if (!added[0]) {
added[0] = true;
return ReactiveSeq.concat(ReactiveSeq.fromIterable(values), ReactiveSeq.of(t._1()));
}
return Stream.of(t._1());
}), ReactiveSeq.deferFromStream(()-> {
return !added[0] ? ReactiveSeq.fromIterable(values) : ReactiveSeq.empty();
}
));
}
default ReactiveSeq<T> insertAt(int pos, ReactiveSeq<? extends T> values){
代码示例来源:origin: com.oath.cyclops/cyclops
}),ReactiveSeq.deferFromStream(()-> {
return !added[0] ? ReactiveSeq.of(values) : ReactiveSeq.empty();
内容来源于网络,如有侵权,请联系作者删除!