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, () -> {

        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");

import org.jspecify.annotations.NullUnmarked;

/**
 * Unit tests for {@link Flushables}.
 *
 * <p>Checks proper flushing behavior, and ensures that IOExceptions on Flushable.flush() are not
 * propagated out from the {@link Flushables#flush} method if {@code swallowException} is true.
 *
 * @author Michael Lancaster
 */
@NullUnmarked
public class FlushablesTest extends TestCase {
  private Flushable mockFlushable;

/**
 * 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);

 *
 * Other exception types cancel the current call:
 *
 *  * For synchronous calls made with [Call.execute], the exception is propagated to the caller.
 *
 *  * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller
 *    indicating that the call was canceled. The interceptor's exception is delivered to the current

import org.jspecify.annotations.NullUnmarked;

/**
 * Unit tests for {@link Flushables}.
 *
 * <p>Checks proper flushing behavior, and ensures that IOExceptions on Flushable.flush() are not
 * propagated out from the {@link Flushables#flush} method if {@code swallowException} is true.
 *
 * @author Michael Lancaster
 */
@NullUnmarked
public class FlushablesTest extends TestCase {
  private Flushable mockFlushable;

        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());

    response, err := conn.SingleRequest(ctx, grid.HandlerDiskInfo, payload)
```

If the error type is `*RemoteErr`, then the error was returned by the remote server. Otherwise it is a local error.

Context timeouts are propagated, and a default timeout of 1 minute is added if none is specified.

There is no cancellation propagation for single payload requests.
When the context is canceled, the request will return at once with an appropriate error.

    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) {

 * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the
 * 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.