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

ReactiveSeq.flatMapStream介绍

[英]flatMap operation

assertThat(ReactiveSeq.of(1,2,3)

[中]平面地图操作

assertThat(ReactiveSeq.of(1,2,3)

代码示例

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

/**
 * flatMap operation
 *
 * <pre>
 * {@code
 *     assertThat(Streamable.of(1,2,3)
 *                      .flatMapStream(i->IntStream.of(i))
 *                      .toList(),equalTo(Arrays.asList(1,2,3)));
 * }
 * </pre>
 *
 * @param fn to be applied
 * @return new stage in Sequence with flatMap operation to be lazily applied
*/
default <R> Streamable<R> flatMapStream(final Function<? super T, BaseStream<? extends R, ?>> fn) {
  return fromStream(this.stream().flatMapStream(fn));
}

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

@Test
public void testFlatMap(){
  System.out.println("Result = " + of( asList("1","10"), asList("2"),asList("3"),asList("4"))
      .flatMapStream( list -> list.stream() ).collect(Collectors.toList()));
  assertThat(of( asList("1","10"), asList("2"),asList("3"),asList("4")).flatMapStream( list -> list.stream() ).collect(Collectors.toList()
          ),hasItem("10"));
}
@Test

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

@Test
public void testFlatMap(){
  System.out.println("Result = " + of( asList("1","10"), asList("2"),asList("3"),asList("4"))
      .flatMapStream( list -> list.stream() ).collect(Collectors.toList()));
  assertThat(of( asList("1","10"), asList("2"),asList("3"),asList("4")).flatMapStream( list -> list.stream() ).collect(Collectors.toList()
          ),hasItem("10"));
}
@Test

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

@Test
public void testFlatMap(){
  assertThat(of( asList("1","10"), asList("2"),asList("3"),asList("4")).flatMapStream( list -> list.stream() ).collect(Collectors.toList()
          ),hasItem("10"));
}

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

@Test
public void testFlatMap(){
  assertThat(of( asList("1","10"), asList("2"),asList("3"),asList("4")).flatMapStream( list -> list.stream() ).collect(Collectors.toList()
          ),hasItem("10"));
}
@Test

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

@Test
public void testFlatMap(){
  assertThat(of( asList("1","10"), asList("2"),asList("3"),asList("4")).flatMapStream( list -> list.stream() ).to(Streamable::fromStream).collect(Collectors.toList()
          ),hasItem("10"));
}

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

/**
 * flatMap operation
 *
 * <pre>
 * {@code
 *     assertThat(Streamable.of(1,2,3)
 *                      .flatMapStream(i->IntStream.of(i))
 *                      .toList(),equalTo(Arrays.asList(1,2,3)));
 * }
 * </pre>
 *
 * @param fn to be applied
 * @return new stage in Sequence with flatMap operation to be lazily applied
*/
default <R> Streamable<R> flatMapStream(final Function<? super T, BaseStream<? extends R, ?>> fn) {
  return fromStream(this.stream().flatMapStream(fn));
}

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

@Override
default <R> FutureStream<R> flatMapStream(final Function<? super U, BaseStream<? extends R, ?>> fn) {
  return fromStream(ReactiveSeq.oneShotStream(stream())
                 .flatMapStream(fn));
}