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

LongStream.mapToInt介绍

[英]Returns an IntStream consisting of the results of applying the given function to the elements of this stream.

This is an intermediate operation.
[中]返回一个IntStream，该IntStream包含将给定函数应用于该流元素的结果。
这是一个intermediate operation。

代码示例

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

public LongMapToIntAction(LongToIntFunction mapper) {
  super(s -> s.mapToInt(requireNonNull(mapper)), IntStream.class, MAP_TO);
}

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

@Override
public IntStream mapToInt(LongToIntFunction mapper) {
  requireNonNull(mapper);
  if (STRICT) {
    return toStream().mapToInt(mapper);
  }
  return SingletonIntStream.of(mapper.applyAsInt(element));
}

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

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

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

@Override
public IntStream mapToInt(LongToIntFunction mapper) {
  return wrap(stream().mapToInt(mapper));
}

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

public LongMapToIntAction(LongToIntFunction mapper) {
  super(s -> s.mapToInt(requireNonNull(mapper)), IntStream.class, MAP_TO);
}

代码示例来源：origin: mzheravin/exchange-core

private static int maxWidth(int minWidth, long[]... arrays) {
  return Arrays.stream(arrays)
      .flatMapToLong(Arrays::stream)
      .mapToInt(p -> String.valueOf(p).length())
      .max()
      .orElse(minWidth);
}

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

@Override
public ExIntStream mapToInt(LongToIntFunction mapper) {
  return ExIntStream.of(stream.mapToInt(mapper));
}

代码示例来源：origin: se.ugli.ugli-commons/ugli-commons

@Override
public IntStream mapToInt(final LongToIntFunction mapper) {
  return new IntResourceStream(stream.mapToInt(mapper), closeOnTerminalOperation, resources);
}

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

@Override
public IntStream mapToInt(LongToIntFunction mapper) {
  return wrap(stream().mapToInt(mapper));
}

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

@Override
public IntStreamEx mapToInt(LongToIntFunction mapper) {
  return new IntStreamEx(stream().mapToInt(mapper), context);
}

代码示例来源：origin: com.simiacryptus/mindseye-test

/**
 * Shuffle int stream.
 *
 * @param stream the stream
 * @return the int stream
 */
public static IntStream shuffle(@Nonnull IntStream stream) {
 // http://primes.utm.edu/lists/small/10000.txt
 long coprimeA = 41387;
 long coprimeB = 9967;
 long ringSize = coprimeA * coprimeB - 1;
 @Nonnull IntToLongFunction fn = x -> (x * coprimeA * coprimeA) % ringSize;
 @Nonnull LongToIntFunction inv = x -> (int) ((x * coprimeB * coprimeB) % ringSize);
 @Nonnull IntUnaryOperator conditions = x -> {
  assert x < ringSize;
  assert x >= 0;
  return x;
 };
 return stream.map(conditions).mapToLong(fn).sorted().mapToInt(inv);
}

代码示例来源：origin: com.simiacryptus/mindseye-labs

/**
 * Shuffle int stream.
 *
 * @param stream the stream
 * @return the int stream
 */
public static IntStream shuffle(@Nonnull IntStream stream) {
 // http://primes.utm.edu/lists/small/10000.txt
 long coprimeA = 41387;
 long coprimeB = 9967;
 long ringSize = coprimeA * coprimeB - 1;
 @Nonnull IntToLongFunction fn = x -> (x * coprimeA * coprimeA) % ringSize;
 @Nonnull LongToIntFunction inv = x -> (int) ((x * coprimeB * coprimeB) % ringSize);
 @Nonnull IntUnaryOperator conditions = x -> {
  assert x < ringSize;
  assert x >= 0;
  return x;
 };
 return stream.map(conditions).mapToLong(fn).sorted().mapToInt(inv);
}

代码示例来源：origin: com.simiacryptus/mindseye

/**
 * Shuffle int stream.
 *
 * @param stream the stream
 * @return the int stream
 */
public static IntStream shuffle(@Nonnull IntStream stream) {
 // http://primes.utm.edu/lists/small/10000.txt
 long coprimeA = 41387;
 long coprimeB = 9967;
 long ringSize = coprimeA * coprimeB - 1;
 @Nonnull IntToLongFunction fn = x -> (x * coprimeA * coprimeA) % ringSize;
 @Nonnull LongToIntFunction inv = x -> (int) ((x * coprimeB * coprimeB) % ringSize);
 @Nonnull IntUnaryOperator conditions = x -> {
  assert x < ringSize;
  assert x >= 0;
  return x;
 };
 return stream.map(conditions).mapToLong(fn).sorted().mapToInt(inv);
}

代码示例来源：origin: org.neo4j/graph-algorithms-algo

concurrency,
dampingFactor,
sourceNodeIds.mapToInt(graph::toMappedNodeId).filter(mappedId -> mappedId != -1L).toArray(),
graph,
graph,

代码示例来源：origin: neo4j-contrib/neo4j-graph-algorithms

private IntStream idStream(@Name(value = "start", defaultValue = "null") Object start, Graph graph, int limit) {
  int nodeCount = Math.toIntExact(graph.nodeCount());
  if (start instanceof String) {
    String label = start.toString();
    int labelId = transaction.tokenRead().nodeLabel(label);
    int countWithLabel = Math.toIntExact(transaction.dataRead().countsForNodeWithoutTxState(labelId));
    NodeLabelIndexCursor cursor = transaction.cursors().allocateNodeLabelIndexCursor();
    transaction.dataRead().nodeLabelScan(labelId, cursor);
    cursor.next();
    LongStream ids;
    if (limit == -1) {
      ids = LongStream.range(0, countWithLabel).map( i -> cursor.next() ? cursor.nodeReference() : -1L );
    } else {
      int[] indexes = ThreadLocalRandom.current().ints(limit + 1, 0, countWithLabel).sorted().toArray();
      IntStream deltas = IntStream.range(0, limit).map(i -> indexes[i + 1] - indexes[i]);
      ids = deltas.mapToLong(delta -> { while (delta > 0 && cursor.next()) delta--;return cursor.nodeReference(); });
    }
    return ids.mapToInt(graph::toMappedNodeId).onClose(cursor::close);
  } else if (start instanceof Collection) {
    return ((Collection)start).stream().mapToLong(e -> ((Number)e).longValue()).mapToInt(graph::toMappedNodeId);
  } else if (start instanceof Number) {
    return LongStream.of(((Number)start).longValue()).mapToInt(graph::toMappedNodeId);
  } else {
    if (nodeCount < limit) {
      return IntStream.range(0,nodeCount).limit(limit);
    } else {
      return IntStream.generate(() -> ThreadLocalRandom.current().nextInt(nodeCount)).limit(limit);
    }
  }
}

代码示例来源：origin: org.neo4j/graph-algorithms-algo

private IntStream idStream(@Name(value = "start", defaultValue = "null") Object start, Graph graph, int limit) {
  int nodeCount = Math.toIntExact(graph.nodeCount());
  if (start instanceof String) {
    String label = start.toString();
    int labelId = transaction.tokenRead().nodeLabel(label);
    int countWithLabel = Math.toIntExact(transaction.dataRead().countsForNodeWithoutTxState(labelId));
    NodeLabelIndexCursor cursor = transaction.cursors().allocateNodeLabelIndexCursor();
    transaction.dataRead().nodeLabelScan(labelId, cursor);
    cursor.next();
    LongStream ids;
    if (limit == -1) {
      ids = LongStream.range(0, countWithLabel).map( i -> cursor.next() ? cursor.nodeReference() : -1L );
    } else {
      int[] indexes = ThreadLocalRandom.current().ints(limit + 1, 0, countWithLabel).sorted().toArray();
      IntStream deltas = IntStream.range(0, limit).map(i -> indexes[i + 1] - indexes[i]);
      ids = deltas.mapToLong(delta -> { while (delta > 0 && cursor.next()) delta--;return cursor.nodeReference(); });
    }
    return ids.mapToInt(graph::toMappedNodeId).onClose(cursor::close);
  } else if (start instanceof Collection) {
    return ((Collection)start).stream().mapToLong(e -> ((Number)e).longValue()).mapToInt(graph::toMappedNodeId);
  } else if (start instanceof Number) {
    return LongStream.of(((Number)start).longValue()).mapToInt(graph::toMappedNodeId);
  } else {
    if (nodeCount < limit) {
      return IntStream.range(0,nodeCount).limit(limit);
    } else {
      return IntStream.generate(() -> ThreadLocalRandom.current().nextInt(nodeCount)).limit(limit);
    }
  }
}

代码示例来源：origin: neo4j-contrib/neo4j-graph-algorithms

concurrency,
dampingFactor,
sourceNodeIds.mapToInt(graph::toMappedNodeId).filter(mappedId -> mappedId != -1L).toArray(),
graph,
graph,

代码示例来源：origin: saalfeldlab/n5

blockSize = Arrays.stream(dimensions).mapToInt(a -> (int)a).toArray();