CurlRequest request = new CurlRequest(Method.GET, url);

        // Add additional param
        request.param("new", "value");

        assertNotNull(request);
    }

    @Test
    public void testMultipleThreadPoolCalls() {
        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");
        ForkJoinPool pool1 = new ForkJoinPool(2);

                SuggestItem.Kind.DOCUMENT);

        String[][] readings2Query = new String[2][];
        readings2Query[0] = new String[] { "zenbun", "fuga" };
        readings2Query[1] = new String[] { "kensaku", "fuga" };
        String[] tags2Query = new String[] { "tag4" };

     */
    @Test
    public void testWriteParameterWordsWireFormat() {
        // Arrange
        SmbComWrite write = new SmbComWrite();
        write.setParam(0x1234, 0x5678L, 100, new byte[10], 0, 10);
        byte[] dst = new byte[20];

        // Act
        int bytesWritten = write.writeParameterWordsWireFormat(dst, 0);

        // Assert

    Type t1 = new TypeCapture<T1>() {}.capture();
    Type t2 = new TypeCapture<T2>() {}.capture();
    assertEquals(t2, new TypeResolver().where(t1, t2).resolveType(t1));
  }

  public <T> void testWhere_genericArrayMapping() {
    Type t = new TypeCapture<T>() {}.capture();
    assertEquals(
        String.class,
        new TypeResolver()
            .where(new TypeCapture<T[]>() {}.capture(), String[].class)

            lsarpc.LsarRefDomainList domains = new lsarpc.LsarRefDomainList();
            domains.count = 1;
            domains.max_count = 1;
            domains.domains = new lsarpc.LsarTrustInformation[1];
            domains.domains[0] = new lsarpc.LsarTrustInformation();
            domains.domains[0].name = new UnicodeString("TESTDOM", false);
            domains.domains[0].sid = new jcifs.dcerpc.rpc.sid_t();

        void testInterfaceHierarchy() {
            // Create instances
            SmbInfoAllocation smbInfo = new SmbInfoAllocation();
            FileFsSizeInformation sizeInfo = new FileFsSizeInformation();
            FileFsFullSizeInformation fullSizeInfo = new FileFsFullSizeInformation();

            // All should be FileSystemInformation
            assertTrue(smbInfo instanceof FileSystemInformation);

        response = new Smb2QueryDirectoryResponse(mockConfig, expectInfoClass);

        assertNotNull(response);
        assertNull(response.getResults()); // Should be null before decoding
    }

    @Test
    @DisplayName("Test getResults returns null initially")
    void testGetResultsInitiallyNull() {
        response = new Smb2QueryDirectoryResponse(mockConfig, (byte) 0x03);

  private final ExecutionList list = new ExecutionList();

  public void testRunOnPopulatedList() throws Exception {
    Executor exec = newCachedThreadPool();
    CountDownLatch countDownLatch = new CountDownLatch(3);
    list.add(new MockRunnable(countDownLatch), exec);
    list.add(new MockRunnable(countDownLatch), exec);
    list.add(new MockRunnable(countDownLatch), exec);

  public void testRotate() {
    testRotate(new boolean[] {}, -1, new boolean[] {});
    testRotate(new boolean[] {}, 0, new boolean[] {});
    testRotate(new boolean[] {}, 1, new boolean[] {});

    testRotate(new boolean[] {true}, -2, new boolean[] {true});
    testRotate(new boolean[] {true}, -1, new boolean[] {true});
    testRotate(new boolean[] {true}, 0, new boolean[] {true});
    testRotate(new boolean[] {true}, 1, new boolean[] {true});

            int threadCount = 10;
            Thread[] threads = new Thread[threadCount];
            boolean[] success = new boolean[threadCount];

            for (int i = 0; i < threadCount; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    try {
                        Smb2EchoRequest req = new Smb2EchoRequest(mockConfig);