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

LongStream.count介绍

[英]Returns the count of elements in this stream. This is a special case of a reduction and is equivalent to:

return map(e -> 1L).sum();

This is a terminal operation.
[中]返回此流中元素的计数。这是reduction的一个特例，相当于：

return map(e -> 1L).sum();

这是一个terminal operation。

代码示例

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

@Override
  public boolean mightHaveLogsToPrune()
  {
    return pruneStrategy.findLogVersionsToDelete( logFiles.getHighestLogVersion() ).count() > 0;
  }
}

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

@Override
public <T> long apply(
  final SqlStreamOptimizerInfo<ENTITY> info,        
  final SqlStreamTerminator<ENTITY> sqlStreamTerminator,
  final LongPipeline pipeline
) {
  requireNonNull(info);
  requireNonNull(sqlStreamTerminator);
  requireNonNull(pipeline);
  return sqlStreamTerminator.optimize(pipeline).getAsLongStream().count();
}

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

default long count(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().count();
}

代码示例来源：origin: SonarSource/sonarqube

private void expectPermissions(PermissionQuery query, Collection<Integer> expectedUserIds, UserPermissionDto... expectedPermissions) {
 assertThat(underTest.selectUserIdsByQuery(dbSession, query)).containsExactly(expectedUserIds.toArray(new Integer[0]));
 List<UserPermissionDto> currentPermissions = underTest.selectUserPermissionsByQuery(dbSession, query, expectedUserIds);
 assertThat(currentPermissions).hasSize(expectedPermissions.length);
 List<Tuple> expectedPermissionsAsTuple = Arrays.stream(expectedPermissions)
  .map(expectedPermission -> tuple(expectedPermission.getUserId(), expectedPermission.getPermission(), expectedPermission.getComponentId(),
   expectedPermission.getOrganizationUuid()))
  .collect(Collectors.toList());
 assertThat(currentPermissions)
  .extracting(UserPermissionDto::getUserId, UserPermissionDto::getPermission, UserPermissionDto::getComponentId, UserPermissionDto::getOrganizationUuid)
  .containsOnly(expectedPermissionsAsTuple.toArray(new Tuple[0]));
 // test method "countUsers()"
 long distinctUsers = stream(expectedPermissions).mapToLong(UserPermissionDto::getUserId).distinct().count();
 assertThat((long) underTest.countUsersByQuery(dbSession, query)).isEqualTo(distinctUsers);
}

代码示例来源：origin: apache/incubator-druid

.count();
 Assert.assertEquals(i + 1, numDataSourceOfExpectedRemainingSegments);
} else {

代码示例来源：origin: palantir/atlasdb

@VisibleForTesting
Long getOutcomeCount(BackgroundCompactor.CompactionOutcome outcome) {
  if (outcome == BackgroundCompactor.CompactionOutcome.SHUTDOWN) {
    return shutdown ? 1L : 0L;
  }
  return Arrays.stream(reservoir.getSnapshot().getValues())
      .filter(l -> l == outcome.ordinal())
      .count();
}

代码示例来源：origin: palantir/atlasdb

private Long getOutcomeCount(SweepOutcome outcome) {
  if (outcome == SweepOutcome.SHUTDOWN) {
    return shutdown ? 1L : 0L;
  }
  if (outcome == SweepOutcome.FATAL) {
    return fatal ? 1L : 0L;
  }
  return Arrays.stream(reservoir.getSnapshot().getValues())
      .filter(l -> l == outcome.ordinal())
      .count();
}

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

@Override
public long count() {
  return stream.count();
}

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

private boolean shouldMerge(Set<Actor> actors) {
  return actors.size() > 1 && (actors.stream().anyMatch(a -> a.user.userId == 0)
      || actors.stream().mapToLong(a -> a.user.userId).distinct().count() > 1);
}

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

@Override
public long count() {
  // This is a terminal operation
  return evalAndclose(() -> stream.count());
}

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

@Override
public <T> long apply(
  final SqlStreamOptimizerInfo<ENTITY> info,        
  final SqlStreamTerminator<ENTITY> sqlStreamTerminator,
  final LongPipeline pipeline
) {
  requireNonNull(info);
  requireNonNull(sqlStreamTerminator);
  requireNonNull(pipeline);
  return sqlStreamTerminator.optimize(pipeline).getAsLongStream().count();
}

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

default long count(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().count();
}

代码示例来源：origin: org.neo4j/neo4j-kernel

@Override
  public boolean mightHaveLogsToPrune()
  {
    return pruneStrategy.findLogVersionsToDelete( logFiles.getHighestLogVersion() ).count() > 0;
  }
}

代码示例来源：origin: com.palantir.atlasdb/atlasdb-impl-shared

@VisibleForTesting
Long getOutcomeCount(BackgroundCompactor.CompactionOutcome outcome) {
  if (outcome == BackgroundCompactor.CompactionOutcome.SHUTDOWN) {
    return shutdown ? 1L : 0L;
  }
  return Arrays.stream(reservoir.getSnapshot().getValues())
      .filter(l -> l == outcome.ordinal())
      .count();
}

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

@Override
public long count() {
  if (context.fjp != null)
    return context.terminate(stream()::count);
  return stream().count();
}

代码示例来源：origin: com.palantir.atlasdb/atlasdb-impl-shared

private Long getOutcomeCount(SweepOutcome outcome) {
  if (outcome == SweepOutcome.SHUTDOWN) {
    return shutdown ? 1L : 0L;
  }
  if (outcome == SweepOutcome.FATAL) {
    return fatal ? 1L : 0L;
  }
  return Arrays.stream(reservoir.getSnapshot().getValues())
      .filter(l -> l == outcome.ordinal())
      .count();
}

代码示例来源：origin: org.apache.james/apache-james-mailbox-cassandra

@Test
  void nextModSeqShouldGenerateUniqueValuesWhenParallelCalls() {
    int nbEntries = 100;
    long nbValues = LongStream.range(0, nbEntries)
      .parallel()
      .map(Throwing.longUnaryOperator(x -> modSeqProvider.nextModSeq(null, mailbox)))
      .distinct()
      .count();
    assertThat(nbValues).isEqualTo(nbEntries);
  }
}

代码示例来源：origin: padreati/rapaio

break;
case LONG:
  countValue = (int) var.stream().mapToLong(VSpot::getLong).distinct().count();
  break;
case DOUBLE: