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

ReactiveSeq.fanOut介绍

暂无

代码示例

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

@Test
public void fanOut2(){
  assertThat(Spouts.of(1,2,3,4)
      .fanOut(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)));
}

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

@Test
public void fanOut(){
  assertThat(Spouts.of(1,2,3,4)
      .fanOut(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)
      .fanOut(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)
      .fanOut(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 triplicateFanOut() {
  for (int k = 0; k < ITERATIONS; k++) {
    System.out.println("******************Triplicate & zip.. " + k);
    System.out.println("******************Triplicate & zip.. " + k);
    System.out.println("******************Triplicate & zip.. " + k);
    System.out.println("******************Triplicate & zip.. " + k);
    List<Integer> res = of(1, 2, 3, 4, 5, 6, 7, 8, 9)
        .fanOut(s1 -> s1.peek(System.out::println).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();
    assertThat("List is "  + res,res, Matchers.hasItems(6, 100, 2000, 12, 400, 5000, 18, 700, 8000));
  }
}

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

@Test
public void fanOut(){
  assertThat(ReactiveSeq.of(1,2,3,4)
        .fanOut(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)
      .fanOut(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)
             .fanOut(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 triplicateFanOut(){
  assertThat(ReactiveSeq.of(1,2,3,4,5,6,7,8,9)
      .fanOut(s1->s1.peek(System.out::println).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)));
}
@Test

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

@Test
public void fanOut() {
  for (int k = 0; k < ITERATIONS; k++) {
    assertThat(of(1, 2, 3, 4)
        .fanOut(s1 -> s1.filter(i -> i % 2 == 0).map(i -> i * 2),
            s2 -> s2.filter(i -> i % 2 != 0).map(i -> i * 100))
        .toList(), Matchers.hasItems(4, 100, 8, 300));
    assertThat(of(1, 2, 3, 4, 5, 6, 7, 8, 9)
        .fanOut(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));
    assertThat(of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
        .fanOut(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.hasItems(8, 100, 2000, 30000, 16, 500, 6000, 70000, 24, 900, 10000, 110000));
  }
}

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

@Override
default <R> ReactiveSeq<R> fanOut(Function<? super ReactiveSeq<U>, ? extends ReactiveSeq<? extends R>> path1,
                  Function<? super ReactiveSeq<U>, ? extends ReactiveSeq<? extends R>> path2,
                  Function<? super ReactiveSeq<U>, ? extends ReactiveSeq<? extends R>> path3,
                  Function<? super ReactiveSeq<U>, ? extends ReactiveSeq<? extends R>> path4) {
  return fromStream(stream().fanOut(path1, path2, path3,path4));
}

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

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

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

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