}
            latch.countDown();
        });

        Thread t2 = new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                execJob.jvmOptions("-Xms" + i + "m");
            }
            latch.countDown();
        });

        t1.start();
        t2.start();

        assertTrue(latch.await(5, TimeUnit.SECONDS));

            TestFessLabels labels = new TestFessLabels();
            labels.testAssertPropertyNotNull(null);
            fail("Should throw IllegalArgumentException");
        } catch (IllegalArgumentException e) {
            assertEquals("The argument 'property' for message should not be null.", e.getMessage());
        }
    }

    /**

            HtmlNext htmlNext = (HtmlNext) baseField.get(null);
            assertTrue("Base path should match pattern", htmlNext.getRoutingPath().startsWith(basePath));
        }

        if (detailsField != null) {
            HtmlNext htmlNext = (HtmlNext) detailsField.get(null);
            assertTrue("Details path should match pattern", htmlNext.getRoutingPath().contains("_details.jsp"));
        }

        if (editField != null) {

      constructor = type.getConstructor();
    } catch (NoSuchMethodException e) {
      return arbitraryConstantInstanceOrNull(type);
    }
    constructor.setAccessible(true); // accessibility check is too slow
    try {
      return constructor.newInstance();
    } catch (InstantiationException | IllegalAccessException impossible) {
      throw new AssertionError(impossible);
    } catch (InvocationTargetException e) {

              + " map in that class.");
    }
    Object result;
    try {
      result = supplier.get();
    } catch (Throwable t) {
      if (predicate.apply(t)) {
        // We are careful to set up INSTANCE_OF to match each Predicate to its target Class.
        @SuppressWarnings("unchecked")
        T caught = (T) t;
        return caught;
      }
      throw new AssertionError(

    if (address.url.host ==
      this
        .route()
        .address.url.host
    ) {
      return true // This connection is a perfect match.
    }

    // At this point we don't have a hostname match. But we still be able to carry the request if
    // our connection coalescing requirements are met. See also:
    // https://hpbn.co/optimizing-application-delivery/#eliminate-domain-sharding

        return stemmerOverrideService.getStemmerOverrideFile(form.dictId).map(file -> {
            try (InputStream inputStream = form.stemmerOverrideFile.getInputStream()) {
                file.update(inputStream);
            } catch (final IOException e) {
                logger.warn("Failed to process a request.", e);
                throwValidationError(messages -> messages.addErrorsFailedToUploadStemmeroverrideFile(GLOBAL),

   * @throws IOException if an I/O error occurs while opening the stream
   * @since 33.4.0 (but since 22.0 in the JRE flavor)
   */
  @MustBeClosed
  // If users use this when they shouldn't, we hope that NewApi will catch subsequent Stream calls.
  @IgnoreJRERequirement
  public Stream<String> lines() throws IOException {
    BufferedReader reader = openBufferedStream();
    return reader.lines().onClose(() -> closeUnchecked(reader));
  }

              + " map in that class.");
    }
    Object result;
    try {
      result = supplier.get();
    } catch (Throwable t) {
      if (predicate.apply(t)) {
        // We are careful to set up INSTANCE_OF to match each Predicate to its target Class.
        @SuppressWarnings("unchecked")
        T caught = (T) t;
        return caught;
      }
      throw new AssertionError(

     *
     * @param paramTypes
     *            array of parameter types
     * @param args
     *            array of arguments
     * @param index
     *            index of the argument to operate on
     * @return {@literal true} if the argument was converted to match the type
     */