baos.write(buffer.array(), 0, 4);
    }

    /**
     * Test constructor with KERB_CHECKSUM_HMAC_MD5 type.
     *
     * @throws IOException if an I/O error occurs
     * @throws PACDecodingException if the PAC is malformed
     */
    @Test
    void testConstructorKerbChecksumHmacMd5() throws IOException, PACDecodingException {
        // Prepare data
        ByteArrayOutputStream baos = new ByteArrayOutputStream();

    SomeCheckedException cause = new SomeCheckedException();
    SomeChainingException thrown = new SomeChainingException(cause);

    assertThat(thrown).hasCauseThat().isSameInstanceAs(cause);
    assertThat(getCauseAs(thrown, SomeCheckedException.class)).isSameInstanceAs(cause);
    assertThat(getCauseAs(thrown, Exception.class)).isSameInstanceAs(cause);

    ClassCastException expected =
        assertThrows(

     * @throws FileAccessException
     *             If the file cannot be accessed or created.
     */
    public DynamicProperties(final File file) {
        // check path
        if (file == null) {
            throw new FileAccessException("ECL0108");
        }

        this.propertiesFile = file;

        verifyNoMoreInteractions(smbFile);
    }

    @Test
    @DisplayName("accept: propagates SmbException thrown by dependency")
    void accept_propagatesSmbException() throws Exception {
        // Arrange: filter delegates to isDirectory which may throw SmbException
        SmbFileFilter filter = f -> f.isDirectory();
        SmbException boom = new SmbException("io error");

    for (Thread t : threads) {
      t.join();
    }

    if (thrown.get() != null) {
      throw thrown.get();
    }
    assertEquals(1, count.get());
  }

  @J2ktIncompatible
  @GwtIncompatible // Thread
  @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
  public void testSynchronizedSupplierThreadSafe() throws InterruptedException {
    Supplier<Integer> nonThreadSafe =

        // Arrange
        String msg = "downgrade not allowed";

        // Act & Assert - verify thrown type and message
        SMBProtocolDowngradeException thrown = assertThrows(SMBProtocolDowngradeException.class, () -> {
            throw new SMBProtocolDowngradeException(msg);
        });
        assertEquals(msg, thrown.getMessage());
    }

        CIFSException thrown = assertThrows(CIFSException.class, () -> {
            watchHandle.close();
        });

        assertEquals("Failed to close handle", thrown.getMessage());
        verify(watchHandle, times(1)).close();
    }

    /**
     * Test AutoCloseable behavior with try-with-resources
     */
    @Test
    void testAutoCloseable() throws CIFSException {

    /**
     * Ensures the exception is thrown and captured via assertThrows with the right message.
     */
    @Test
    void assertThrowsCapturesExceptionAndMessage() {
        // Act & Assert
        SmbEndOfFileException thrown = assertThrows(SmbEndOfFileException.class, () -> {
            throw new SmbEndOfFileException();
        });
        assertEquals("Unexpectedly reached end of file", thrown.getMessage());
    }

    /**

            throw new TransportException(expectedMessage);
        });

        // Test throwing and catching with cause
        RuntimeException cause = new RuntimeException("Cause");
        TransportException thrown = assertThrows(TransportException.class, () -> {
            throw new TransportException(cause);
        });
        assertEquals(cause, thrown.getCause());

 * order that they are added.
 *
 * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
 * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
 * thrown by {@linkplain MoreExecutors#directExecutor direct execution}) will be caught and logged.
 *
 * @author Nishant Thakkar