// Create a spy to verify method call
        NetShareEnumResponse spyResponse = spy(new NetShareEnumResponse(mockConfig));

        setNumEntries(spyResponse, 0);
        byte[] buffer = new byte[100];

        spyResponse.readDataWireFormat(buffer, 0, buffer.length);

        // Verify setUseUnicode was called with false
        verify(spyResponse).setUseUnicode(false);
    }

    @Test

    resultFuture = buildChainingFuture(inputFuture);
    listener = new MockFutureListener(resultFuture);
  }

  public void testFutureGetBeforeCallback() throws Exception {
    // Verify that get throws a timeout exception before the callback is called.
    assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS));
  }

  public void testFutureGetThrowsWrappedException() throws Exception {

 * limitations under the License.
 */

package com.google.common.io;

import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;

import java.io.Flushable;
import java.io.IOException;
import junit.framework.TestCase;
import org.jspecify.annotations.NullUnmarked;

/**
 * Unit tests for {@link Flushables}.
 *

        // When & Then
        assertThrows(ArrayIndexOutOfBoundsException.class, () -> {
            response.readBytesWireFormat(buffer, offset);
        });
    }

    @Test
    @DisplayName("Should verify inheritance from ServerMessageBlock2Response")
    void testInheritance() {
        // Then
        assertTrue(response instanceof ServerMessageBlock2Response);
        assertTrue(response instanceof ServerMessageBlock2);

    public void test_execute_queryBuilderCreation() {
        // Execute the job
        purgeDocJob.execute();

        // Verify the query builder was created correctly
        assertNotNull(deleteQuery);
        assertTrue(deleteQuery instanceof RangeQueryBuilder);

        // Verify the range query parameters
        RangeQueryBuilder rangeQuery = (RangeQueryBuilder) deleteQuery;

        outputBuffer = new byte[1024];
        response = new TransCallNamedPipeResponse(mockConfig, outputBuffer);
    }

    @Test
    void testConstructor() {
        assertNotNull(response);
        // Verify that the outputBuffer is stored properly
        byte[] testData = new byte[] { 1, 2, 3, 4, 5 };
        TransCallNamedPipeResponse testResponse = new TransCallNamedPipeResponse(mockConfig, testData);

  private const val ALT_IPA_NAME = 7

  override fun verify(
    host: String,
    session: SSLSession,
  ): Boolean =
    if (!host.isAscii()) {
      false
    } else {
      try {
        verify(host, session.peerCertificates[0] as X509Certificate)
      } catch (_: SSLException) {
        false
      }
    }

  fun verify(
    host: String,
    certificate: X509Certificate,
  ): Boolean =

import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.Mockito.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

class SourcesTest {
    @TempDir
    Path tempDir;

    @Test
    void testFromPath() {
        Path path = Paths.get("/tmp");

            assertTrue(bytes.length >= 48); // Minimum size
            // Verify signature
            assertTrue(Arrays.equals(Type2Message.NTLMSSP_SIGNATURE, Arrays.copyOfRange(bytes, 0, 8)));
            // Verify message type
            assertEquals(Type2Message.NTLMSSP_TYPE2, Type2Message.readULong(bytes, 8));
            // Verify flags
            assertEquals(message.getFlags(), Type2Message.readULong(bytes, 20));
        }

- [ ] Provide integration tests (under `<subproject>/src/integTest`) to verify changes from a user perspective.
- [ ] Provide unit tests (under `<subproject>/src/test`) to verify logic.
- [ ] Update User Guide, DSL Reference, and Javadoc for public-facing changes.
- [ ] Ensure that tests pass sanity check: `./gradlew sanityCheck`.