// Second reject (should be ignored)
        deferred.reject(new RuntimeException("second"));
        // Third reject (should be ignored)
        deferred.reject(new RuntimeException("third"));

        Thread.sleep(100);

        assertEquals("Error callback should only be invoked once", 1, callbackCount.get());
        assertEquals("Should receive first error", "first", receivedMessage.get());
    }

    }

    @Test
    @DisplayName("Should handle null path")
    void testNullPath() {
        // When creating with null path
        Smb2TreeConnectRequest reqWithNull = new Smb2TreeConnectRequest(mockConfig, null);

        // Then - should not throw during construction
        assertNotNull(reqWithNull);

        assertTrue(decoded > 0, "Decode should return positive length");

        assertEquals(NtStatus.NT_STATUS_MORE_PROCESSING_REQUIRED, resp.getStatus());
        assertArrayEquals(blob, resp.getBlob(), "Security blob should match");
        assertEquals(sessionFlags, resp.getSessionFlags(), "Session flags should decode");
        assertTrue(resp.isLoggedInAsGuest(), "Guest/anonymous should be detected");

        assertNotNull(connection1, "First connection should not be null.");
        assertNotNull(connection2, "Second connection should not be null.");
        assertTrue(connection1 instanceof NtlmHttpURLConnection, "First connection should be wrapped.");
        assertTrue(connection2 instanceof NtlmHttpURLConnection, "Second connection should be wrapped.");
    }

                defaultReadingConverter, defaultReadingConverter, defaultNormalizer, analyzer);

        // Whitespace-only content should produce empty or filtered items
        // Items with blank words should be filtered
        for (SuggestItem item : items) {
            assertTrue("Items should not have blank text", item.getText().trim().length() > 0);
        }
    }

    @Test

            // key3 should definitely exist (just created)
            assertNotNull(limitedManager.getLease(key3));

            // key1 should have been evicted (oldest)
            assertNull(limitedManager.getLease(key1));

            // key2 should still exist (not the oldest)
            assertNotNull(limitedManager.getLease(key2));
        } finally {

    @DisplayName("Should setup response correctly")
    void testSetupResponse() {
        // Given
        Response resp = mock(Response.class);

        // When
        response.setupResponse(resp);

        // Then - nothing should happen (empty implementation)
        verifyNoInteractions(resp);
    }

    @Test
    @DisplayName("Should read valid negotiate response from wire format")

        } else {
            fail("Inconsistent behavior: first=" + first + ", second=" + second);
        }

        // Third call should return the same cached Subject instance
        Subject third = auth.getSubject();
        assertEquals(second, third, "Subsequent calls should return same cached result");

        // Refresh should clear the cache
        auth.refresh();

    }

    @Test
    @DisplayName("Constructor should initialize TransWaitNamedPipeResponse")
    void testConstructor() {
        // Assert
        assertNotNull(response);
        // Verify parent class is properly initialized
        assertTrue(response instanceof SmbComTransactionResponse);
    }

    @Test
    @DisplayName("writeSetupWireFormat should return 0")
    void testWriteSetupWireFormat() {
        // Arrange

		t.Errorf("Count should work, but got err %v", err)
	}
	if count1 != 1 {
		t.Errorf("Count with group should be 1, but got count: %v", count1)
	}

	var count2 int64
	if err := DB.Model(&Company{}).Where("name in ?", []string{"company_count_group_b", "company_count_group_c"}).Group("name").Count(&count2).Error; err != nil {
		t.Errorf("Count should work, but got err %v", err)
	}
	if count2 != 2 {