// Mock the streams
        SmbPipeInputStream mockIn = mock(SmbPipeInputStream.class);
        SmbPipeOutputStream mockOut = mock(SmbPipeOutputStream.class);

        // Create spy and override getInput/getOutput
        SmbPipeHandleImpl spyHandle = spy(handle);
        doReturn(mockIn).when(spyHandle).getInput();
        doReturn(mockOut).when(spyHandle).getOutput();

        // Setup mock behavior

import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyInt;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;

    }

    @Test
    @DisplayName("send retries on transport errors and restores request/response state")
    void send_retries_on_transportError() throws Exception {
        // Create a spy to track method calls
        SmbTreeConnection c = spy(newConn());

        // Prepare a minimal locator
        SmbResourceLocatorImpl loc = new SmbResourceLocatorImpl(ctx, smbUrl("smb://srv/share/path"));

        @Test
        @DisplayName("Should execute bind operation successfully")
        void testBindSuccess() throws DcerpcException, IOException {
            // Given: Spy to intercept sendrecv calls
            TestDcerpcHandle spyHandle = spy(new TestDcerpcHandle(mockContext, mockBinding));
            doNothing().when(spyHandle).sendrecv(any(DcerpcMessage.class));

            // When: Binding the handle

    void optionsMap_notMutated_verifyNoWrites() {
        // Arrange: create a regular map first, then spy on it
        Map<String, Object> originalMap = new HashMap<>();
        originalMap.put("refreshKrb5Config", "true");

        @SuppressWarnings("unchecked")
        Map<String, Object> spyOpts = spy(originalMap);

        // Reset the spy to clear any prior invocations from setup
        reset(spyOpts);

import static org.mockito.Mockito.atLeastOnce;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

        assertEquals(0, blob.length(), "length() should return 0 when internal array is null");
    }

    @Spy
    SecurityBlob spyBlob = new SecurityBlob();

    // Illustrates Mockito interaction verification by spying on set() and validating behavior
    @Test
    @DisplayName("Mockito spy: verify set() interaction and resulting behavior")
    void spy_verifySetInteraction() {
        // Arrange

import static org.mockito.Mockito.mock;

@ExtendWith(MockitoExtension.class)
class DefaultToolchainsBuilderTest {
    private static final String LS = System.lineSeparator();

    @Spy
    private DefaultToolchainsReader toolchainsReader;

    @Spy
    private DefaultToolchainsWriter toolchainsWriter;

    @InjectMocks
    private DefaultToolchainsBuilder toolchainBuilder;

    @BeforeEach
    void onSetup() {

     * @throws IOException
     */
    @Test
    void testGettersTriggerHandshake() throws IOException {
        // Arrange
        // Spy on the connection to verify handshake() is called
        NtlmHttpURLConnection spiedConnection = spy(ntlmConnection);
        doNothing().when(spiedConnection).connect();
        // Mock the handshake process to do nothing complex
        mockResponse(HTTP_OK, "OK", null, null);

import static org.mockito.Mockito.clearInvocations;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

import java.lang.reflect.Field;

import org.junit.jupiter.api.BeforeEach;