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

ReactiveSeq.parallelFanOut介绍

暂无

代码示例

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

@Test
public void parallelFanOut() {
  assertThat(of(1, 2, 3, 4)
      .parallelFanOut(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 2 == 0).map(i -> i * 2),
          s2 -> s2.filter(i -> i % 2 != 0).map(i -> i * 100))
      .collect(Collectors.toList()), Matchers.equalTo(Arrays.asList(4, 100, 8, 300)));
  assertThat(of(1, 2, 3, 4)
      .parallelFanOutZipIn(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 2 == 0).map(i -> i * 2),
          s2 -> s2.filter(i -> i % 2 != 0).map(i -> i * 100), (a, b) -> a + b)
      .toList(), Matchers.equalTo(Arrays.asList(104, 308)));
}

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

@Test
public void parallelFanOut2(){
  assertThat(Spouts.of(1,2,3,4)
      .parallelFanOut(ForkJoinPool.commonPool(), s1->s1.filter(i->i%2==0).map(i->i*2),
          s2->s2.filter(i->i%2!=0).map(i->i*100))
      .toList(), Matchers.equalTo(Arrays.asList(4,100,8,300)));
  assertThat(Spouts.of(1,2,3,4,5,6,7,8,9)
      .parallelFanOut(ForkJoinPool.commonPool(),s1->s1.filter(i->i%3==0).map(i->i*2),
          s2->s2.filter(i->i%3==1).map(i->i*100),
          s3->s3.filter(i->i%3==2).map(i->i*1000))
      .toList(), Matchers.equalTo(Arrays.asList(6, 100, 2000, 12, 400, 5000, 18, 700, 8000)));
  assertThat(Spouts.of(1,2,3,4,5,6,7,8,9,10,11,12)
      .parallelFanOut(ForkJoinPool.commonPool(),s1->s1.filter(i->i%4==0).map(i->i*2),
          s2->s2.filter(i->i%4==1).map(i->i*100),
          s3->s3.filter(i->i%4==2).map(i->i*1000),
          s4->s4.filter(i->i%4==3).map(i->i*10000))
      .toList(), Matchers.equalTo(Arrays.asList(8, 100, 2000, 30000, 16, 500, 6000, 70000, 24, 900, 10000, 110000)));
}
@Test

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

@Test
public void parallelFanOut(){
  assertThat(ReactiveSeq.of(1,2,3,4)
      .parallelFanOut(ForkJoinPool.commonPool(), s1->s1.filter(i->i%2==0).map(i->i*2),
          s2->s2.filter(i->i%2!=0).map(i->i*100))
      .toList(),equalTo(Arrays.asList(4,100,8,300)));
  assertThat(ReactiveSeq.of(1,2,3,4)
      .parallelFanOutZipIn(ForkJoinPool.commonPool(), s1->s1.filter(i->i%2==0).map(i->i*2),
          s2->s2.filter(i->i%2!=0).map(i->i*100),(a,b)->a+b)
      .toList(),equalTo(Arrays.asList(104,308)));
}
@Test

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

@Test
public void parallelFanOut2(){
  assertThat(ReactiveSeq.of(1,2,3,4)
      .parallelFanOut(ForkJoinPool.commonPool(),s1->s1.filter(i->i%2==0).map(i->i*2),
          s2->s2.filter(i->i%2!=0).map(i->i*100))
      .toList(),equalTo(Arrays.asList(4,100,8,300)));
  assertThat(ReactiveSeq.of(1,2,3,4,5,6,7,8,9)
      .parallelFanOut(ForkJoinPool.commonPool(),s1->s1.filter(i->i%3==0).map(i->i*2),
          s2->s2.filter(i->i%3==1).map(i->i*100),
          s3->s3.filter(i->i%3==2).map(i->i*1000))
      .toList(),equalTo(Arrays.asList(6, 100, 2000, 12, 400, 5000, 18, 700, 8000)));
  assertThat(ReactiveSeq.of(1,2,3,4,5,6,7,8,9,10,11,12)
      .parallelFanOut(ForkJoinPool.commonPool(),s1->s1.filter(i->i%4==0).map(i->i*2),
          s2->s2.filter(i->i%4==1).map(i->i*100),
          s3->s3.filter(i->i%4==2).map(i->i*1000),
          s4->s4.filter(i->i%4==3).map(i->i*10000))
      .toList(),equalTo(Arrays.asList(8, 100, 2000, 30000, 16, 500, 6000, 70000, 24, 900, 10000, 110000)));
}
@Test

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

@Test
public void triplicateParallelFanOut2() {
  for (int k = 0; k < ITERATIONS; k++) {
    assertThat(of(1, 2, 3, 4, 5, 6, 7, 8, 9)
        .parallelFanOut(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 3 == 0).map(i -> i * 2),
            s2 -> s2.filter(i -> i % 3 == 1).map(i -> i * 100),
            s3 -> s3.filter(i -> i % 3 == 2).map(i -> i * 1000))
        .toList(), Matchers.hasItems(6, 100, 2000, 12, 400, 5000, 18, 700, 8000));
  }
}

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

@Test
public void parallelFanOut2() {
  for (int k = 0; k < ITERATIONS; k++) {
    assertThat(of(1, 2, 3, 4)
        .parallelFanOut(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 2 == 0).map(i -> i * 2),
            s2 -> s2.filter(i -> i % 2 != 0).map(i -> i * 100))
        .toList(), Matchers.equalTo(Arrays.asList(4, 100, 8, 300)));
    assertThat(of(1, 2, 3, 4, 5, 6, 7, 8, 9)
        .parallelFanOut(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 3 == 0).map(i -> i * 2),
            s2 -> s2.filter(i -> i % 3 == 1).map(i -> i * 100),
            s3 -> s3.filter(i -> i % 3 == 2).map(i -> i * 1000))
        .toList(), Matchers.equalTo(Arrays.asList(6, 100, 2000, 12, 400, 5000, 18, 700, 8000)));
    assertThat(of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
        .parallelFanOut(ForkJoinPool.commonPool(), s1 -> s1.filter(i -> i % 4 == 0).map(i -> i * 2),
            s2 -> s2.filter(i -> i % 4 == 1).map(i -> i * 100),
            s3 -> s3.filter(i -> i % 4 == 2).map(i -> i * 1000),
            s4 -> s4.filter(i -> i % 4 == 3).map(i -> i * 10000))
        .toList(), Matchers.equalTo(Arrays.asList(8, 100, 2000, 30000, 16, 500, 6000, 70000, 24, 900, 10000, 110000)));
  }
}

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

@Override
default <R> FutureStream<R> parallelFanOut(ForkJoinPool fj, Function<? super Stream<U>, ? extends Stream<? extends R>> path1,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path2) {
  return fromStream(stream().parallelFanOut(fj,path1,path2));
}

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

@Override
default <R> FutureStream<R> parallelFanOut(ForkJoinPool fj, Function<? super Stream<U>, ? extends Stream<? extends R>> path1,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path2,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path3) {
  return fromStream(stream().parallelFanOut(fj,path1, path2, path3));
}

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

@Override
default <R> FutureStream<R> parallelFanOut(ForkJoinPool fj, Function<? super Stream<U>, ? extends Stream<? extends R>> path1,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path2,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path3,
                      Function<? super Stream<U>, ? extends Stream<? extends R>> path4) {
  return fromStream(stream().parallelFanOut(fj,path1, path2, path3,path4));
}