if (crawlerThread != null) {
            try {
                crawlerThread.join();
            } catch (final Exception e) {
                logger.info("Interrupted crawling process: name={}", crawlerThread.getName());
            }
        }
    }

  @GwtIncompatible // reflection
  public void testConstants_charset() throws Exception {
    for (Field field : getConstantFields()) {
      Optional<Charset> charset = ((MediaType) field.get(null)).charset();
      if (field.getName().endsWith("_UTF_8")) {
        assertThat(charset).hasValue(UTF_8);
      } else {
        assertThat(charset).isAbsent();
      }
    }
  }

  @J2ktIncompatible
  @GwtIncompatible // reflection

      boolean isFunctional();
    }

    static final String UNSAFE_COMPARATOR_NAME =
        LexicographicalComparatorHolder.class.getName() + "$UnsafeComparator";

    static final Comparator<byte[]> BEST_COMPARATOR = getBestComparator();

    @SuppressWarnings({
      // b/345822163
      "SunApi",
      "deprecation",

                    facetField = facetResponse.getFieldList().stream().map(field -> {
                        final Map<String, Object> fieldMap = new HashMap<>(2, 1f);
                        fieldMap.put("name", field.getName());
                        fieldMap.put("result", field.getValueCountMap().entrySet().stream().map(e -> {
                            final Map<String, Object> valueCount = new HashMap<>(2, 1f);

                    //skip the named tests for this file
                    skippedFilesWithTestAndReason.get(file).forEach(fullTestNameAndReasonPair -> {
                        String prefix = file.getName().replace(".yml", "/");
                        String singleTestName = fullTestNameAndReasonPair.getLeft().replaceAll(".*" + prefix, "");

HSPLokhttp3/internal/http2/Hpack$Reader;-><init>(Lokio/Source;III)V
HSPLokhttp3/internal/http2/Hpack$Reader;->evictToRecoverBytes(I)I
HSPLokhttp3/internal/http2/Hpack$Reader;->getName(I)Lokio/ByteString;
HSPLokhttp3/internal/http2/Hpack$Reader;->insertIntoDynamicTable(ILokhttp3/internal/http2/Header;)V
HSPLokhttp3/internal/http2/Hpack$Reader;->readByteString()Lokio/ByteString;

            return searchers.toArray(new RankFusionSearcher[0]);
        }
        final RankFusionSearcher[] availableSearchers = searchers.stream()
                .filter(searcher -> availableSearcherNameSet.contains(searcher.getName()))
                .toArray(RankFusionSearcher[]::new);
        if (availableSearchers.length == 0) {
            if (logger.isDebugEnabled()) {

        sb.append("id=").append(this.getId());
        sb.append(",mirrorOf=").append(this.getMirrorOf());
        sb.append(",url=").append(this.getUrl());
        sb.append(",name=").append(this.getName());
        if (isBlocked()) {
            sb.append(",blocked");
        }
        sb.append("]");
        return sb.toString();
    }
            ]]>
          </code>
        </codeSegment>

 *
 * @author Nishant Thakkar
 */
@NullMarked
@GwtCompatible
public class FuturesTest extends TestCase {
  private static final Logger aggregateFutureLogger =
      Logger.getLogger(AggregateFuture.class.getName());
  private final TestLogHandler aggregateFutureLogHandler = new TestLogHandler();

  private static final String DATA1 = "data";
  private static final String DATA2 = "more data";

 *
 * @author Nishant Thakkar
 */
@NullMarked
@GwtCompatible
public class FuturesTest extends TestCase {
  private static final Logger aggregateFutureLogger =
      Logger.getLogger(AggregateFuture.class.getName());
  private final TestLogHandler aggregateFutureLogHandler = new TestLogHandler();

  private static final String DATA1 = "data";
  private static final String DATA2 = "more data";