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

ReactiveSeq.seq介绍

暂无

代码示例

代码示例来源：origin: aol/cyclops

default Seq<Tuple2<T,BigDecimal>> withPercentiles(){
  Seq<T> list = stream().seq();
  int precision = new Double(Math.log10(list.size())).intValue();
  return list.zipWithIndex().map(t -> t.map2(idx -> {
    double d = (idx / new Double(list.size()));
    return new BigDecimal((d*100),new MathContext(precision));
  }));
}
/*

代码示例来源：origin: aol/cyclops

@Override
  public <T> Higher<seq, T> apply(Higher<reactiveSeq, T> a) {
    return a.convert(ReactiveSeq::narrowK).seq();
  }
};

代码示例来源：origin: aol/cyclops

/**
 * Convert this MapX to a Seq via the provided transformation function
 *
 * @param fn Mapping function to transform each Map entry into a single value
 * @return Seq of transformed values
 */
default <T> Seq<T> toSeq(final Function<? super Tuple2<? super K, ? super V>, ? extends T> fn) {
  return Seq.narrow(stream().map(fn)
      .seq());
}

代码示例来源：origin: aol/cyclops

@Test
public void takeRightValues(){
  assertThat(of(1,2,3).takeRight(-1).seq(), Matchers.equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(0).seq(), Matchers.equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(1).seq(), Matchers.equalTo(of(3).seq()));
  assertThat(of(1,2,3).takeRight(2).seq(), Matchers.equalTo(of(2,3).seq()));
  assertThat(of(1,2,3).takeRight(3).seq(), Matchers.equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).takeRight(4).seq(), Matchers.equalTo(of(1,2,3).seq()));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void dropRightValues(){
  assertThat(of(1,2,3).dropRight(-1).seq(), Matchers.equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).dropRight(0).seq(), Matchers.equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).dropRight(1).seq(), Matchers.equalTo(of(1,2).seq()));
  assertThat(of(1,2,3).dropRight(2).seq(), Matchers.equalTo(of(1).seq()));
  assertThat(of(1,2,3).dropRight(3).seq(), Matchers.equalTo(of().seq()));
  assertThat(of(1,2,3).dropRight(4).seq(), Matchers.equalTo(of().seq()));
}
@Test

代码示例来源：origin: aol/cyclops

default double stdDeviation(ToDoubleFunction<T> fn){
  Seq<T> list = stream().seq();
  double avg = list.collect(Collectors.<T>averagingDouble(fn));
  return Math.sqrt( list.stream().mapToDouble(fn)
      .map(i->i-avg)
      .map(i->i*i)
      .average()
      .getAsDouble());
}

代码示例来源：origin: aol/cyclops

@Test
public void takeRightValues(){
  assertThat(of(1,2,3).takeRight(-1).seq(), equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(0).seq(), equalTo(of().seq()));
  assertThat(of(1,2,3).takeRight(1).seq(), equalTo(of(3).seq()));
  assertThat(of(1,2,3).takeRight(2).seq(), equalTo(of(2,3).seq()));
  assertThat(of(1,2,3).takeRight(3).seq(), equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).takeRight(4).seq(), equalTo(of(1,2,3).seq()));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void dropRightValues(){
  assertThat(of(1,2,3).dropRight(-1).seq(),equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).dropRight(0).seq(),equalTo(of(1,2,3).seq()));
  assertThat(of(1,2,3).dropRight(1).seq(),equalTo(of(1,2).seq()));
  assertThat(of(1,2,3).dropRight(2).seq(),equalTo(of(1).seq()));
  assertThat(of(1,2,3).dropRight(3).seq(),equalTo(of().seq()));
  assertThat(of(1,2,3).dropRight(4).seq(),equalTo(of().seq()));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void testSequencePresent() {
  Optional<Seq<Integer>> maybes =Optionals.sequencePresent(Seq.of(Optional.of(10),Optional.empty(),Optional.of(1))).map(s->s.seq());
  assertThat(maybes,equalTo(Optional.of(Seq.of(10,1))));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void map(){
  Five<Integer> two = create(2,2,2, 2,2);
  Five<Integer> mapped = two.map(i->i*100);
  System.out.println(Arrays.deepToString(two.array));
  System.out.println(Arrays.deepToString(mapped.array));
  assertThat(ReactiveSeq.fromIterator(mapped.iterator()).seq(),equalTo(ReactiveSeq.range(0,32).map(i->i*100).seq()));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void testSequence() {
  Optional<ReactiveSeq<Integer>> maybes =Optionals.sequence(Seq.of(Optional.of(10),Optional.of(20),Optional.of(1)));
  assertThat(maybes.map(s->s.seq()),equalTo(Optional.of(Seq.of(10,20,1))));
}
@Test

代码示例来源：origin: aol/cyclops

@Test
public void map(){
  Six<Integer> two = create(2,2,2, 2,2,2);
  Six<Integer> mapped = two.map(i->i*100);
  System.out.println(Arrays.deepToString(two.array));
  System.out.println(Arrays.deepToString(mapped.array));
  assertThat(ReactiveSeq.fromIterator(mapped.iterator()).seq(),equalTo(ReactiveSeq.range(0,64).map(i->i*100).seq()));
}
@Test

代码示例来源：origin: aol/cyclops

public static  <T> ReactiveSeq<T> concat(Publisher<Publisher<T>> pubs){
  return reactiveStream(new ArrayConcatonatingOperator<T>(Spouts.from(pubs).seq()
      .map(p->new PublisherToOperator<T>(p))));
}
public static  <T> ReactiveSeq<T> lazyConcat(Publisher<Publisher<T>> pubs){

代码示例来源：origin: aol/cyclops

public static  <T> ReactiveSeq<T> lazyConcat(Publisher<Publisher<T>> pubs){
  return reactiveStream(new LazyArrayConcatonatingOperator<T>(Spouts.from(pubs).seq()
      .map(p->new PublisherToOperator<T>(p))));
}
public static  <T> ReactiveSeq<T> concat(Stream<? extends T>... streams){

代码示例来源：origin: aol/cyclops

default double populationVariance(ToDoubleFunction<T> fn){
  Seq<T> list = stream().seq();
  double avg = list.collect(Collectors.<T>averagingDouble(fn));
  return (list.map(t -> fn.applyAsDouble(t))
      .map(t -> t - avg)
      .map(t -> t * t)
      .sumDouble(i -> i)/(list.size()));
}

代码示例来源：origin: aol/cyclops

default double variance(ToDoubleFunction<T> fn){
  Seq<T> list = stream().seq();
  double avg = list.collect(Collectors.<T>averagingDouble(fn));
  return (list.map(t -> fn.applyAsDouble(t))
      .map(t -> t - avg)
      .map(t -> t * t)
      .sumDouble(i -> i))/(list.size()-1);
}
default double populationVariance(ToDoubleFunction<T> fn){

代码示例来源：origin: aol/cyclops

@Test
public void scheduleStream(){
  assertThat(of(1,2,3,4).scheduleStream("* * * * * ?", ThreadPools.getStandardSchedular()).seq(),equalTo(Seq.of(1,2,3,4)));
}

代码示例来源：origin: aol/cyclops

@Test
public void splitThenSplit() {
  assertThat(of(1, 2, 3).to().option(), equalTo(Option.of(LazySeq.of(1, 2, 3))));
  // System.out.println(of(1, 2, 3).splitAtHead()._2.listX());
  System.out.println("split " + of(1, 2, 3).splitAtHead()._2().splitAtHead()._2().toList());
  ReactiveSeq<Integer> x = of(1, 2, 3).splitAtHead()._2()
    .splitAtHead()._2();
  System.out.println("s is  " + x.seq());
  Option<Integer> o = of(1, 2, 3).splitAtHead()._2()
                .splitAtHead()._2()
                .splitAtHead()._1();
  System.out.println("o is " + o);
  assertEquals(Option.of(3), o);
}

代码示例来源：origin: com.oath.cyclops/cyclops

/**
 * Convert this MapX to a Seq via the provided transformation function
 *
 * @param fn Mapping function to transform each Map entry into a single value
 * @return Seq of transformed values
 */
default <T> Seq<T> toSeq(final Function<? super Tuple2<? super K, ? super V>, ? extends T> fn) {
  return Seq.narrow(stream().map(fn)
      .seq());
}

代码示例来源：origin: aol/cyclops

@Test
 public void allCombinations3NoOrd() {
   Seq<Seq<Integer>> x = of(1, 2, 3).combinations().map(s -> s.seq()).seq();
   System.out.println(x);
   assertTrue(x.containsValue(Seq.empty()));
   assertTrue(x.containsValue(Seq.of(1)));
   assertTrue(x.containsValue(Seq.of(2)));
   assertTrue(x.containsValue(Seq.of(3)));
   assertTrue(x.containsValue(Seq.of(1,2)));
   assertTrue(x.containsValue(Seq.of(1,3)));
   assertTrue(x.containsValue(Seq.of(2,3)));
   assertTrue(x.containsValue(Seq.of(1,2,3)));
 }
@Test