* KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.artifact.repository.metadata;

import javax.xml.stream.XMLStreamException;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.file.Files;

import org.apache.maven.artifact.Artifact;

        logUpgradeOptions(context);

        UpgradeResult overallResult = UpgradeResult.empty();

        // Filter and execute applicable strategies
        List<UpgradeStrategy> applicableStrategies = strategies.stream()
                .filter(strategy -> strategy.isApplicable(context))
                .toList();

        if (applicableStrategies.isEmpty()) {
            context.warning("No applicable upgrade strategies found");

import java.util.Iterator;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.SortedMap;
import java.util.SortedSet;
import java.util.function.BinaryOperator;
import java.util.stream.Collector;
import org.jspecify.annotations.Nullable;

/**
 * Provides static methods that involve a {@code Table}.
 *
 * <p>See the Guava User Guide article on <a href=

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Objects;
import java.util.function.BiPredicate;
import java.util.stream.Collector;
import org.jspecify.annotations.NullMarked;
import org.jspecify.annotations.Nullable;

/**
 * Tester for {@code Collector} implementations.
 *
 * <p>Example usage:
 *
 * <pre>

   * will be added more than once, with the count summed over all appearances of the element.
   *
   * <p>Note that {@code stream.collect(toMultiset(function, e -> 1, supplier))} is equivalent to
   * {@code stream.map(function).collect(Collectors.toCollection(supplier))}.
   *
   * <p>To collect to an {@link ImmutableMultiset}, use {@link
   * ImmutableMultiset#toImmutableMultiset}.
   *

        private MutableBuildParams() {}

        /**
         * Resets any existing values from previous initializations.
         */
        public void reset() {
            Arrays.stream(BuildParams.class.getDeclaredFields()).filter(f -> Modifier.isStatic(f.getModifiers())).forEach(f -> {
                try {

     */
    public QueryBuilder buildFilterQuery(final String fieldName, final List<String> words) {
        final BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery().minimumShouldMatch(1);
        words.stream().forEach(word -> boolQueryBuilder.should(QueryBuilders.termQuery(fieldName, word)));
        return boolQueryBuilder;
    }

    /**
     * Builds a function score query.
     * @param query The query string.

        // Verify document content
        for (int i = 0; i < 5; i++) {
            final String expectedTitle = NAME_PREFIX + i;
            boolean found = docs.stream().anyMatch(doc -> expectedTitle.equals(doc.get("title")));
            assertTrue(found, "Document with title " + expectedTitle + " should exist");
        }

        logger.info("[END] testBulkCreate");
    }

        Caused by: java.io.IOException: Failed to delete temp directory /var/folders/_2/vxp7qn2x7qzd0zqqm8p128lh0000gq/T/junit-4205933054320696172.
	        at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
         */
        .withDebug(true)
        .withArguments(*args, "--stacktrace", "--no-watch-fs")

    private

                coreEntry.getExportedArtifacts(),
                coreExtensionSelector.selectCoreExtensions(invoker, context));
        List<CoreExtensionEntry> loadedExtensionsEntries =
                loadedExtensions.stream().map(LoadedCoreExtension::entry).toList();
        ClassRealm containerRealm =
                setupContainerRealm(context.logger, classWorld, coreRealm, extClassPath, loadedExtensionsEntries);