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

IntStream.flatMap介绍

[英]Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. Each mapped stream is java.util.stream.BaseStream#close() after its contents have been placed into this stream. (If a mapped stream is nullan empty stream is used, instead.)

This is an intermediate operation.
[中]返回一个流，该流由将提供的映射函数应用于每个元素而生成的映射流的内容替换该流的每个元素的结果组成。每个映射流都是java。util。流动BaseStream的内容放入此流后关闭（）。（如果映射流为空，则使用空流。）
这是一个intermediate operation。

代码示例

代码示例来源：origin: speedment/speedment

public IntFlatMapAction(IntFunction<? extends IntStream> mapper) {
  super(s -> s.flatMap(requireNonNull(mapper)), IntStream.class, StandardBasicAction.FLAT_MAP);
}

代码示例来源：origin: speedment/speedment

@Override
public IntStream flatMap(IntFunction<? extends IntStream> mapper) {
  requireNonNull(mapper);
  if (STRICT) {
    return toStream().flatMap(mapper);
  }
  return mapper.apply(element);
}

代码示例来源：origin: google/guava

public void testMapWithIndex_intStream_closeIsPropagated_unsized() {
 testMapWithIndex_intStream_closeIsPropagated(
   IntStream.of(0).flatMap(unused -> IntStream.of(1, 2, 3)));
}

代码示例来源：origin: speedment/speedment

@Override
  public IntStream build(boolean parallel) {
    return previous().build(parallel).flatMap(mapper);
  }
}

代码示例来源：origin: speedment/speedment

@Override
public IntStream flatMap(IntFunction<? extends IntStream> mapper) {
  return wrap(stream().flatMap(mapper));
}

代码示例来源：origin: prestodb/presto

@Test
  public void testMassive()
  {
    BlockBuilder inputBlockBuilder = BIGINT.createBlockBuilder(null, 5000);

    TypedHistogram typedHistogram = new SingleTypedHistogram(BIGINT, 1000);
    IntStream.range(1, 2000)
        .flatMap(i -> IntStream.iterate(i, IntUnaryOperator.identity()).limit(i))
        .forEach(j -> BIGINT.writeLong(inputBlockBuilder, j));

    Block inputBlock = inputBlockBuilder.build();
    for (int i = 0; i < inputBlock.getPositionCount(); i++) {
      typedHistogram.add(i, inputBlock, 1);
    }

    MapType mapType = mapType(BIGINT, BIGINT);
    BlockBuilder out = mapType.createBlockBuilder(null, 1);
    typedHistogram.serialize(out);
    Block outputBlock = mapType.getObject(out, 0);
    for (int i = 0; i < outputBlock.getPositionCount(); i += 2) {
      assertEquals(BIGINT.getLong(outputBlock, i + 1), BIGINT.getLong(outputBlock, i));
    }
  }
}

代码示例来源：origin: apache/tinkerpop

private static Optional<Object[]> remove(final Object keyToRemove, final Object... keyValues) {
  final List list = Arrays.asList(keyValues);
  final List revised = IntStream.range(0, list.size())
      .filter(i -> i % 2 == 0)
      .filter(i -> !keyToRemove.equals(list.get(i)))
      .flatMap(i -> IntStream.of(i, i + 1))
      .mapToObj(i -> list.get(i))
      .collect(Collectors.toList());
  return revised.size() > 0 ? Optional.of(revised.toArray()) : Optional.empty();
}

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

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Integer>, ? extends ReactiveSeq<Integer>> concatMapnts(IntFunction<? extends IntStream> b){
  return a->a.ints(i->i,s->s.flatMap(b));
}
/*

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

public static Function<? super ReactiveSeq<Integer>, ? extends ReactiveSeq<Integer>> concatMapnts(IntFunction<? extends IntStream> b){
  return a->a.ints(i->i,s->s.flatMap(b));
}
/*

代码示例来源：origin: com.aol.cyclops/cyclops-base

@Override
public IntStream flatMap(IntStream t, Function fn) {
  return t.flatMap( i-> (IntStream)fn.apply(i));
}

代码示例来源：origin: org.apache.tinkerpop/gremlin-core

private static Optional<Object[]> remove(final Object keyToRemove, final Object... keyValues) {
  final List list = Arrays.asList(keyValues);
  final List revised = IntStream.range(0, list.size())
      .filter(i -> i % 2 == 0)
      .filter(i -> !keyToRemove.equals(list.get(i)))
      .flatMap(i -> IntStream.of(i, i + 1))
      .mapToObj(i -> list.get(i))
      .collect(Collectors.toList());
  return revised.size() > 0 ? Optional.of(revised.toArray()) : Optional.empty();
}

代码示例来源：origin: com.tinkerpop/gremlin-core

private static Optional<Object[]> remove(final Object keyToRemove, final Object... keyValues) {
  final List list = Arrays.asList(keyValues);
  final List revised = IntStream.range(0, list.size())
      .filter(i -> i % 2 == 0)
      .filter(i -> !keyToRemove.equals(list.get(i)))
      .flatMap(i -> IntStream.of(i, i + 1))
      .mapToObj(list::get)
      .collect(Collectors.toList());
  return revised.size() > 0 ? Optional.of(revised.toArray()) : Optional.empty();
}

代码示例来源：origin: com.aol.simplereact/cyclops-react

public static Function<? super ReactiveSeq<Integer>, ? extends ReactiveSeq<Integer>> flatMapInts(IntFunction<? extends IntStream> b){
  return a->a.ints(i->i,s->s.flatMap(b));
}
/*

代码示例来源：origin: net.dongliu/commons-lang

@Override
public ExIntStream flatMap(IntFunction<? extends IntStream> mapper) {
  return ExIntStream.of(stream.flatMap(mapper));
}

代码示例来源：origin: stackoverflow.com

static String convert(String str) {
  int[] cps = str.codePoints()
      .flatMap((cp) ->
        Character.isLetterOrDigit(cp) && cp < 128
        ? IntStream.of(cp)
        : String.valueOf(cp).codePoints())
          .toArray();
  return new String(cps, 0, cps.length);
}

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

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Integer>, ? extends ReactiveSeq<Integer>> concatMapnts(IntFunction<? extends IntStream> b){
  return a->a.ints(i->i,s->s.flatMap(b));
}
/*

代码示例来源：origin: stackoverflow.com

public static int[] generate(String first, String second) {
 return (first + second)
  .chars()
  .flatMap(i -> IntStream.range(0, i)
          .boxed()
          .sorted(Collections.reverseOrder())
          .mapToInt(Integer::valueOf))
  .toArray();
}

代码示例来源：origin: one.util/streamex

@Override
public IntStreamEx flatMap(IntFunction<? extends IntStream> mapper) {
  return new IntStreamEx(stream().flatMap(mapper), context);
}

代码示例来源：origin: com.speedment.runtime/runtime-core

@Override
public IntStream flatMap(IntFunction<? extends IntStream> mapper) {
  return wrap(stream().flatMap(mapper));
}

代码示例来源：origin: com.google.guava/guava-tests

public void testMapWithIndex_intStream_closeIsPropagated_unsized() {
 testMapWithIndex_intStream_closeIsPropagated(
   IntStream.of(0).flatMap(unused -> IntStream.of(1, 2, 3)));
}