*/
    @Test
    void testClose_throwsException() {
        doThrow(new RuntimeException("Failed to close")).when(smbTree).close();

        assertThrows(RuntimeException.class, () -> smbTree.close(), "Should propagate exception when close fails");
    }

    /**
     * Test for AutoCloseable functionality.
     * Verifies that SmbTree can be used in try-with-resources.
     */
    @Test
    void testAutoCloseable() {

        verify(configuration, atLeastOnce()).getOemEncoding();
        verifyNoMoreInteractions(cifsContext, configuration);
    }

    @Test
    @DisplayName("getPreNTLMResponse: unsupported OEM encoding propagates as runtime exception")
    void testGetPreNTLMResponse_invalidEncoding() {
        // Arrange
        when(cifsContext.getConfig()).thenReturn(configuration);

        when(nego.isSigningNegotiated()).thenReturn(false);
        assertFalse(session.isSignatureSetupRequired());
    }

    @Test
    @DisplayName("reauthenticate propagates transport failures")
    void testReauthenticatePropagates() throws Exception {
        SmbSessionImpl session = newSession();
        // Cause the inner reauthenticate to fail at first transport call

          nextHeaderIndex += entriesToEvict
        }
        return entriesToEvict
      }

      /**
       * Read `byteCount` bytes of headers from the source stream. This implementation does not
       * propagate the never indexed flag of a header.
       */
      @Throws(IOException::class)
      fun readHeaders() {
        while (!source.exhausted()) {
          val b = source.readByte() and 0xff
          when {

        verify(resp, atLeastOnce()).reset();
        // Verify disconnect was called on retry
        verify(c, atLeastOnce()).disconnect(eq(true));
    }

    @Test
    @DisplayName("send honors NO_RETRY and propagates error immediately")
    void send_noRetry_param() throws Exception {
        SmbTreeConnection c = newConn();
        SmbTreeImpl tree = mock(SmbTreeImpl.class);
        when(tree.acquire(false)).thenReturn(tree);

            throw new RuntimeException("Test exception");
        };

        try {
            ThreadDumpUtil.processThreadDump(exceptionConsumer);
            fail("Should propagate RuntimeException from consumer");
        } catch (RuntimeException e) {
            assertEquals("Test exception", e.getMessage());
        }
    }

* kubeadm: fix "certificate-authority" files not being pre-loaded when using file discovery ([#80966](https://github.com/kubernetes/kubernetes/pull/80966), [@neolit123](https://github.com/neolit123))
* Errors from pod volume set up are now propagated as pod events. ([#80369](https://github.com/kubernetes/kubernetes/pull/80369), [@jsafrane](https://github.com/jsafrane))

 *   <li>It doesn't support backpressure and other features needed for resilience.
 *   <li>It doesn't provide much control of threading.
 *   <li>It doesn't offer much monitoring.
 *   <li>It doesn't propagate exceptions, so apps don't have a way to react to them.
 *   <li>It doesn't interoperate well with RxJava, coroutines, and other more commonly used
 *       alternatives.

        RuntimeException thrownException = assertThrows(RuntimeException.class, () -> {
            delegatingConfig.getResponseTimeout();
        });

        assertSame(testException, thrownException, "Should propagate exception from delegate");
        verify(mockDelegate).getResponseTimeout();
    }

    @Test
    @DisplayName("Multiple method calls should result in multiple delegate calls")

            assertEquals("S-1-5-10-20", domSidCap.getValue().toString());
        }

        @Test
        @DisplayName("initContext then accessors propagate resolver CIFSException as log-only (no throw)")
        void testResolveWeakCIFSExceptionIsIgnored() throws Exception {
            SID sid = new SID("S-1-5-21-1-2-3");