StorageClient client = new StorageClient() {
            @Override
            protected java.io.File createTempFile(String prefix, String suffix, java.io.File directory) {
                // Verify the prefix is correct
                assertTrue("Temp file prefix should be 'crawler-StorageClient-'", prefix.equals("crawler-StorageClient-"));
                assertEquals("Temp file suffix should be '.out'", ".out", suffix);

      - name: Publish local snapshot
        run: ./gradlew publishToMavenLocal

      - name: Run maven test
        working-directory: ./maven-tests
        run: ./mvnw -q verify

  test_java_modules:
    runs-on: ubuntu-latest

    steps:
      - name: Checkout
        uses: actions/checkout@v6

      - name: Configure JDK
        uses: actions/setup-java@v5

                4 + 4 + // AvTargetName header + data
                4; // EOL
        assertEquals(expectedLength, encoded.length, "Encoded length should match expected");

        // Verify EOL at the end
        int eolPos = encoded.length - 4;
        assertEquals(AvPair.MsvAvEOL, SMBUtil.readInt2(encoded, eolPos), "Should end with EOL");

	c.items[key] = ent
	c.addToBucket(ent) // adds the entry to the appropriate bucket and sets entry.expireBucket

	evict := c.size > 0 && c.evictList.Length() > c.size
	// Verify size not exceeded
	if evict {
		c.removeOldest()
	}
	return evict
}

// Get looks up a key's value from the cache.
func (c *LRU[K, V]) Get(key K) (value V, ok bool) {
	c.mu.Lock()

      assertThrows(
          NullPointerException.class, () -> builder.addAll((Iterable<String>) iterableWithNulls));
    }
  }

  /**
   * Verify thread safety by using a collection whose size() may be inconsistent with the actual
   * number of elements and whose elements may change over time.
   *

	// ssh.CheckCert called by ssh.Authenticate accepts certificates
	// with empty principles list so we block those in here.
	if len(cert.ValidPrincipals) == 0 {
		return errSftpCertWithoutPrincipals
	}

	// Verify that certificate provided by user is issued by trusted CA,
	// username in authentication request matches to identities in certificate
	// and that certificate type is correct.
	checker := ssh.CertChecker{}

	if successRedirect != "" {
		redirectURL, err = url.Parse(successRedirect)
		if err != nil {
			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMalformedPOSTRequest), r.URL)
			return
		}
	}

	// Verify policy signature.
	cred, errCode := doesPolicySignatureMatch(formValues)
	if errCode != ErrNone {
		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(errCode), r.URL)
		return
	}

    public void test_threadPriority() throws Exception {
        final Crawler testCrawler = container.getComponent("crawler");

        testCrawler.setThreadPriority(Thread.MAX_PRIORITY);
        // Cannot directly verify thread priority, but ensure no exception
    }

    public void test_setters() throws Exception {
        final Crawler testCrawler = container.getComponent("crawler");

        testCrawler.setNumOfThread(5);

        // Delete by query
        boolean result = SuggestUtil.deleteByQuery(client, settings, TEST_INDEX, QueryBuilders.termQuery("field", "value1"));
        assertTrue(result);

        // Verify deletion
        client.admin().indices().prepareRefresh(TEST_INDEX).execute().actionGet();
        long count = client.prepareSearch(TEST_INDEX)
                .setQuery(QueryBuilders.termQuery("field", "value1"))

    assertThrows(NullPointerException.class, () -> ImmutableList.of("a", null, "b"));
  }

  public void testCreation_generic() {
    List<String> a = ImmutableList.of("a");
    // only verify that there is no compile warning
    ImmutableList<List<String>> unused = ImmutableList.of(a, a);
  }

  public void testCreation_arrayOfArray() {
    String[] array = new String[] {"a"};