verify(mockBuffer).dec_ndr_long();
    }

    /**
     * Test case for the encode method when it throws an NdrException.
     * Verifies that the exception is correctly propagated.
     */
    @Test
    void testEncodeThrowsNdrException() {
        // Given
        ndrObject.setThrowOnEncode(true);

        // When & Then
        assertThrows(NdrException.class, () -> {

import org.jspecify.annotations.Nullable;

/**
 * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
 * the same parameters forwarded and return value forwarded back or exception propagated as is.
 *
 * <p>For example:
 *
 * {@snippet :
 * new ForwardingWrapperTester().testForwarding(Foo.class, new Function<Foo, Foo>() {
 *   public Foo apply(Foo foo) {
 *     return new ForwardingFoo(foo);
 *   }

import org.jspecify.annotations.Nullable;

/**
 * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
 * the same parameters forwarded and return value forwarded back or exception propagated as is.
 *
 * <p>For example:
 *
 * {@snippet :
 * new ForwardingWrapperTester().testForwarding(Foo.class, new Function<Foo, Foo>() {
 *   public Foo apply(Foo foo) {
 *     return new ForwardingFoo(foo);
 *   }

/**
 * Tests for {@link SmbFilenameFilter}. Since the interface only defines
 * a single method, the tests simply ensure that the lambda expression
 * correctly implements the method and that any exception is propagated.
 */
class SmbFilenameFilterTest {

    @Test
    void acceptReturnsTrueWhenNameMatches() throws Exception {
        SmbFile dir = Mockito.mock(SmbFile.class);

        assertTrue(n > 0);
        // Note: In actual implementation, uid is NOT propagated for non-AndX SMBs
        // uid is only set for AndXServerMessageBlock instances (line 167 in AndXServerMessageBlock.java)
        // Only useUnicode is set before the instanceof check (line 149)
        assertEquals(block.useUnicode, next.useUnicode, "useUnicode must be propagated");

        assertEquals(0L, nextReq.getSessionId());

        resp.prepare(nextReq);
        assertEquals(0L, nextReq.getSessionId(), "SessionId should not be propagated before response is received");
    }

    @Test
    @DisplayName("writeBytesWireFormat should return 0 for response class")
    void testWriteBytesWireFormatReturnsZero() throws Exception {

    return nonNull;
  }

  /**
   * Creates a {@link FutureCombiner} that processes the completed futures whether or not they're
   * successful.
   *
   * <p>Any failures from the input futures will not be propagated to the returned future.
   *
   * @since 20.0
   */
  @SafeVarargs
  public static <V extends @Nullable Object> FutureCombiner<V> whenAllComplete(
      ListenableFuture<? extends V>... futures) {

        Supplier<String> supplier = mock(Supplier.class);
        when(supplier.get()).thenThrow(new RuntimeException(new SmbUnsupportedOperationException("boom")));

        // Act & Assert: the exception is propagated and interaction recorded once
        RuntimeException thrown = assertThrows(RuntimeException.class, supplier::get);
        assertInstanceOf(SmbUnsupportedOperationException.class, thrown.getCause());

        // Arrange: configure the mock to throw
        doThrow(new CIFSException("DFS resolution failed")).when(handle).ensureDFSResolved();

        // Act + Assert: exception is propagated with message
        CIFSException ex = assertThrows(CIFSException.class, () -> handle.ensureDFSResolved());
        assertEquals("DFS resolution failed", ex.getMessage());
        verify(handle, times(1)).ensureDFSResolved();

        assertEquals(LoginModuleControlFlag.REQUIRED, e.getControlFlag(), "Control flag should be REQUIRED");
    }

    @Test
    @DisplayName("Custom options are propagated to the AppConfigurationEntry")
    void customOptions_arePropagated() {
        // Arrange
        Map<String, Object> opts = new HashMap<>();
        opts.put("useKeyTab", "true");
        opts.put("storeKey", "true");