本文整理了Java中cyclops.reactive.ReactiveSeq.doubles
方法的一些代码示例,展示了ReactiveSeq.doubles
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReactiveSeq.doubles
方法的具体详情如下:
包路径:cyclops.reactive.ReactiveSeq
类名称:ReactiveSeq
方法名:doubles
[英]Peform intermediate operations on a primitive IntStream (gives improved performance when working with Integers) If this ReactiveSeq has an OfInt Spliterator it will be converted directly to an IntStream, otherwise the provided conversion function will be used.
ReactiveSeq.range(1, 1000)param fn
[中]Peform原始IntStream上的中间操作(在处理整数时提供更好的性能)如果此ReactiveSeq具有OFIT拆分器,它将直接转换为IntStream,否则将使用提供的转换函数
ReactiveSeq.range(1, 1000)param fn
代码示例来源:origin: aol/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> mapDoubles(DoubleUnaryOperator b){
return a->a.doubles(i->i,s->s.map(b));
}
/*
代码示例来源:origin: aol/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
return a->a.doubles(i->i,s->s.filter(b));
}
/*
代码示例来源:origin: aol/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> skipDoubles(long skip){
return a->a.doubles(i->i,s->s.skip(skip));
}
/*
代码示例来源:origin: aol/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> limitDouble(long maxSize){
return a->a.doubles(i->i,s->s.limit(maxSize));
}
/*
代码示例来源:origin: aol/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> flatMapDoubles(DoubleFunction<? extends DoubleStream> b){
return a->a.doubles(i->i,s->s.flatMap(b));
}
/*
代码示例来源:origin: aol/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> skipDoubles(long skip){
return a->a.doubles(i->i,s->s.skip(skip));
}
/*
代码示例来源:origin: aol/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> mapDoubles(DoubleUnaryOperator b){
return a->a.doubles(i->i,s->s.map(b));
}
/*
代码示例来源:origin: aol/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
return a->a.doubles(i->i,s->s.filter(b));
}
/*
代码示例来源:origin: aol/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> flatMapDoubles(DoubleFunction<? extends DoubleStream> b){
return a->a.doubles(i->i,s->s.flatMap(b));
}
/*
代码示例来源:origin: aol/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> limitDouble(long maxSize){
return a->a.doubles(i->i,s->s.limit(maxSize));
}
/*
代码示例来源:origin: aol/cyclops
@Test
public void doubles(){
assertThat(ReactiveSeq.range(1, 1000).doubles(i->i.doubleValue(),s->s.map(i->i*2).filter(i->i<500))
.size(),equalTo(249));
}
@Test
代码示例来源:origin: com.oath.cyclops/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> mapDoubles(DoubleUnaryOperator b){
return a->a.doubles(i->i,s->s.map(b));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> limitDouble(long maxSize){
return a->a.doubles(i->i,s->s.limit(maxSize));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> skipDoubles(long skip){
return a->a.doubles(i->i,s->s.skip(skip));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
return a->a.doubles(i->i,s->s.filter(b));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> mapDoubles(DoubleUnaryOperator b){
return a->a.doubles(i->i,s->s.map(b));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> flatMapDoubles(DoubleFunction<? extends DoubleStream> b){
return a->a.doubles(i->i,s->s.flatMap(b));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> limitDouble(long maxSize){
return a->a.doubles(i->i,s->s.limit(maxSize));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
return a->a.doubles(i->i,s->s.filter(b));
}
/*
代码示例来源:origin: com.oath.cyclops/cyclops
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> skipDoubles(long skip){
return a->a.doubles(i->i,s->s.skip(skip));
}
/*
内容来源于网络,如有侵权,请联系作者删除!