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

Stream.anyMatch介绍

[英]Returns whether any elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determining the result. If the stream is empty then false is returned and the predicate is not evaluated.

This is a short-circuiting terminal operation.
[中]返回此流的任何元素是否与提供的谓词匹配。如果不需要确定结果，则不能对所有元素的谓词求值。如果流为空，则返回false，并且不计算谓词。
这是一个short-circuiting terminal operation。

代码示例

代码示例来源：origin: spring-projects/spring-framework

private AcceptPredicate(Set<MediaType> mediaTypes) {
  super(headers -> {
    List<MediaType> acceptedMediaTypes = acceptedMediaTypes(headers);
    boolean match = acceptedMediaTypes.stream()
        .anyMatch(acceptedMediaType -> mediaTypes.stream()
            .anyMatch(acceptedMediaType::isCompatibleWith));
    traceMatch("Accept", mediaTypes, acceptedMediaTypes, match);
    return match;
  });
  this.mediaTypes = mediaTypes;
}

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

private static boolean isS3Storage(String path)
{
  return SUPPORTED_S3_PREFIXES.stream().anyMatch(path::startsWith);
}

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

private static <T> boolean containsNoneDomain(Map<T, Domain> domains)
{
  return domains.values().stream().anyMatch(Domain::isNone);
}

代码示例来源：origin: spring-projects/spring-data-mongodb

@Override
public boolean inheritsFields() {
  return projections.stream().filter(FieldProjection.class::isInstance) //
      .map(FieldProjection.class::cast) //
      .anyMatch(FieldProjection::isExcluded);
}

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

private boolean splitFields(Method model) {
    return model.getFields().size() >= 3 || model.getFields().stream()
      .anyMatch(f -> !f.getAnnotations().isEmpty());
  }
}

代码示例来源：origin: graphql-java/graphql-java

private boolean hasComments(List<? extends Node> nodes) {
  return nodes.stream().anyMatch(it -> it.getComments().size() > 0);
}

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

private static Map<String, PartitionStatistics> getPartitionsStatistics(SemiTransactionalHiveMetastore metastore, SchemaTableName table, List<HivePartition> hivePartitions)
{
  if (hivePartitions.isEmpty()) {
    return ImmutableMap.of();
  }
  boolean unpartitioned = hivePartitions.stream().anyMatch(partition -> partition.getPartitionId().equals(UNPARTITIONED_ID));
  if (unpartitioned) {
    checkArgument(hivePartitions.size() == 1, "expected only one hive partition");
    return ImmutableMap.of(UNPARTITIONED_ID, metastore.getTableStatistics(table.getSchemaName(), table.getTableName()));
  }
  Set<String> partitionNames = hivePartitions.stream()
      .map(HivePartition::getPartitionId)
      .collect(toImmutableSet());
  return metastore.getPartitionStatistics(table.getSchemaName(), table.getTableName(), partitionNames);
}

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

private static void validatePropertySet(SetRequest request, @Nullable PropertyDefinition definition) {
 checkRequest(definition != null, "Setting '%s' is undefined", request.getKey());
 checkRequest(PropertyType.PROPERTY_SET.equals(definition.type()), "Parameter '%s' is used for setting of property set type only", PARAM_FIELD_VALUES);
 Set<String> fieldKeys = definition.fields().stream().map(PropertyFieldDefinition::key).collect(Collectors.toSet());
 ListMultimap<String, String> valuesByFieldKeys = ArrayListMultimap.create(fieldKeys.size(), request.getFieldValues().size() * fieldKeys.size());
 request.getFieldValues().stream()
  .map(oneFieldValues -> readOneFieldValues(oneFieldValues, request.getKey()))
  .peek(map -> checkRequest(map.values().stream().anyMatch(StringUtils::isNotBlank), MSG_NO_EMPTY_VALUE))
  .flatMap(map -> map.entrySet().stream())
  .peek(entry -> valuesByFieldKeys.put(entry.getKey(), entry.getValue()))
  .forEach(entry -> checkRequest(fieldKeys.contains(entry.getKey()), "Unknown field key '%s' for setting '%s'", entry.getKey(), request.getKey()));
 checkFieldType(request, definition, valuesByFieldKeys);
}

代码示例来源：origin: oracle/helidon

@Override
public boolean isAccepted(MediaType mediaType) {
  Objects.requireNonNull(mediaType, "Parameter 'mediaType' is null!");
  List<MediaType> acceptedTypes = acceptedTypes();
  return acceptedTypes.isEmpty() || acceptedTypes.stream().anyMatch(mediaType);
}

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

@Test
public void testHandleDeadWorker() throws Exception {
 Table table = TEST_UTIL.createTable(TABLE_NAME, FAMILY, TEST_UTIL.KEYS_FOR_HBA_CREATE_TABLE);
 for (int i = 0; i < 10; i++) {
  TEST_UTIL.loadTable(table, FAMILY);
 }
 HRegionServer testServer = TEST_UTIL.getHBaseCluster().getRegionServer(0);
 ProcedureExecutor<MasterProcedureEnv> masterPE = master.getMasterProcedureExecutor();
 List<FileStatus> wals = splitWALManager.getWALsToSplit(testServer.getServerName(), false);
 Assert.assertEquals(1, wals.size());
 TEST_UTIL.getHBaseCluster().killRegionServer(testServer.getServerName());
 TEST_UTIL.waitFor(30000, () -> master.getProcedures().stream()
   .anyMatch(procedure -> procedure instanceof SplitWALProcedure));
 Procedure splitWALProcedure = master.getProcedures().stream()
   .filter(procedure -> procedure instanceof SplitWALProcedure).findAny().get();
 Assert.assertNotNull(splitWALProcedure);
 TEST_UTIL.waitFor(5000, () -> ((SplitWALProcedure) splitWALProcedure).getWorker() != null);
 TEST_UTIL.getHBaseCluster()
   .killRegionServer(((SplitWALProcedure) splitWALProcedure).getWorker());
 ProcedureTestingUtility.waitProcedure(masterPE, splitWALProcedure.getProcId());
 Assert.assertTrue(splitWALProcedure.isSuccess());
 ProcedureTestingUtility.waitAllProcedures(masterPE);
}

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

private static boolean hasSpatialPartitioningAggregation(AggregationNode aggregation)
{
  return aggregation.getAggregations().values().stream()
      .map(Aggregation::getCall)
      .anyMatch(call -> call.getName().toString().equals(NAME) && call.getArguments().size() == 1);
}

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

@Test
public void testCommandManagerLoadsUserCommand() throws Exception {
 Properties props = new Properties();
 props.setProperty(ConfigurationProperties.USER_COMMAND_PACKAGES, "com.examples");
 CommandManager commandManager = new CommandManager(props, null);
 assertThat(
   commandManager.getCommandMarkers().stream().anyMatch(c -> c instanceof UserGfshCommand));
}

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

private void validate(short version, List<AclBindingFilter> filters) {
    if (version == 0) {
      final boolean unsupported = filters.stream()
        .map(AclBindingFilter::patternFilter)
        .map(ResourcePatternFilter::patternType)
        .anyMatch(patternType -> patternType != PatternType.LITERAL && patternType != PatternType.ANY);
      if (unsupported) {
        throw new UnsupportedVersionException("Version 0 only supports literal resource pattern types");
      }
    }

    final boolean unknown = filters.stream().anyMatch(AclBindingFilter::isUnknown);
    if (unknown) {
      throw new IllegalArgumentException("Filters contain UNKNOWN elements");
    }
  }
}

代码示例来源：origin: wuyouzhuguli/FEBS-Shiro

private boolean handleExcludeURL(HttpServletRequest request) {
  if (excludes == null || excludes.isEmpty()) {
    return false;
  }
  String url = request.getServletPath();
  return excludes.stream().map(pattern -> Pattern.compile("^" + pattern)).map(p -> p.matcher(url)).anyMatch(Matcher::find);
}

代码示例来源：origin: hs-web/hsweb-framework

public WebUserTokenInterceptor(UserTokenManager userTokenManager, List<UserTokenParser> userTokenParser,AopMethodAuthorizeDefinitionParser definitionParser) {
  this.userTokenManager = userTokenManager;
  this.userTokenParser = userTokenParser;
  this.parser=definitionParser;
  enableBasicAuthorization = userTokenParser.stream()
      .filter(UserTokenForTypeParser.class::isInstance)
      .anyMatch(parser -> "basic".equalsIgnoreCase(((UserTokenForTypeParser) parser).getTokenType()));
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public boolean canDecode(ResolvableType elementType, @Nullable MimeType mimeType) {
  if (mimeType == null) {
    return true;
  }
  return this.decodableMimeTypes.stream().anyMatch(candidate -> candidate.isCompatibleWith(mimeType));
}

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

private static boolean hasSourceDistributedStage(Set<SqlStageExecution> phase)
{
  return phase.stream().anyMatch(stage -> !stage.getFragment().getPartitionedSources().isEmpty());
}

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

public static List<String> getSansTop25(Collection<String> cwe) {
 return SANS_TOP_25_CWE_MAPPING
  .keySet()
  .stream()
  .filter(k -> cwe.stream().anyMatch(SANS_TOP_25_CWE_MAPPING.get(k)::contains))
  .collect(toList());
}

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

public static boolean dependsOn(WindowNode parent, WindowNode child)
  {
    return parent.getPartitionBy().stream().anyMatch(child.getCreatedSymbols()::contains)
        || (parent.getOrderingScheme().isPresent() && parent.getOrderingScheme().get().getOrderBy().stream().anyMatch(child.getCreatedSymbols()::contains))
        || parent.getWindowFunctions().values().stream()
        .map(WindowNode.Function::getFunctionCall)
        .map(SymbolsExtractor::extractUnique)
        .flatMap(Collection::stream)
        .anyMatch(child.getCreatedSymbols()::contains);
  }
}

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

public boolean hasOrderings()
{
  return aggregations.values().stream()
      .map(Aggregation::getCall)
      .map(FunctionCall::getOrderBy)
      .anyMatch(Optional::isPresent);
}