.Builder()
          .url(server.url("/"))
          .build(),
      )
    val clone = call.clone() // Not cloneWithListener.

    val response = clone.execute()
    assertThat(response.code).isEqualTo(200)
    assertThat(response.body.string()).isEqualTo("abc")
    response.body.close()
    assertThat(eventRecorder.recordedEventTypes()).isEmpty()
  }

        .isTrue();
  }

  public void testFinishToValueAndCloser_throwsIfCalledTwice() throws Exception {
    ClosingFuture<Closeable> closingFuture =
        ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
    closingFuture.finishToValueAndCloser(
        new NoOpValueAndCloserConsumer<>(), finishToValueAndCloserExecutor);
    assertThrows(

            executor.shutdown();
        }
    }

    /**
     * Test close() method
     */
    @Test
    void testClose() throws CIFSException {
        // Execute
        watchHandle.close();

        // Verify close was called
        verify(watchHandle, times(1)).close();
    }

    /**
     * Test close() method throwing CIFSException
     */
    @Test

        }

        @Test
        @DisplayName("Should close pool with active transports")
        void testClosePoolWithActiveTransports() throws CIFSException {
            // Given
            when(transportPool.close()).thenReturn(true);

            // When
            boolean result = transportPool.close();

            // Then
            assertTrue(result);
            verify(transportPool).close();

            return invocation.getArgument(1);
        });

        // When: Create iterator and close multiple times
        NetServerEnumIterator iterator = new NetServerEnumIterator(parent, treeHandle, "*", 0, null);

        iterator.close();
        iterator.close(); // Second close should be safe

        // Then: Tree handle should be released only once
        verify(treeHandle, times(1)).release();

                            timingRatio, TIMING_TOLERANCE, timeStart, timeMiddle, timeEnd));
        } finally {
            // Clean up resources
            baseAuth.close();
            startAuth.close();
            middleAuth.close();
            endAuth.close();
        }
    }

    /**
     * Test constant-time comparison with various password lengths.
     */
    @Test

            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarClose.class));

        // Close once
        handle.close();

        // Act
        // Try to close again
        handle.close();

        // Assert
        // Verify sendrecv was called once for open and only once for close
        verify(mockDcerpcHandle, times(1)).sendrecv(any(MsrpcLsarOpenPolicy2.class));

    void testClose_True() throws CIFSException {
        // Test close() method when true
        when(mockDelegate.close()).thenReturn(true);
        assertTrue(cifsContextWrapper.close());
        verify(mockDelegate).close();
    }

    @Test
    void testClose_False() throws CIFSException {
        // Test close() method when false
        when(mockDelegate.close()).thenReturn(false);

public class ClosingFutureFinishToFutureTest extends AbstractClosingFutureTest {
  public void testFinishToFuture_throwsIfCalledTwice() throws Exception {
    ClosingFuture<Closeable> closingFuture =
        ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor);
    FluentFuture<Closeable> unused = closingFuture.finishToFuture();
    assertThrows(
        IllegalStateException.class,
        () -> {

	w := newMetacacheWriter(&buf, 1<<20)
	defer w.Close()
	err := r.readFn(func(object metaCacheEntry) bool {
		err := w.write(object)
		if err != nil {
			t.Fatal(err)
		}
		return true
	})
	r.Close()
	if err != io.EOF {
		t.Fatal(err)
	}
	err = w.Close()
	if err != nil {
		t.Fatal(err)
	}

	r = newMetacacheReader(&buf)
	defer r.Close()
	names, err := r.readNames(-1)