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

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

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

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));
}
/*

相关文章

微信公众号

最新文章

更多

ReactiveSeq类方法