* not fail a test when an exception is thrown from one of its {@link TearDown} instances, but
   * this is subject to change. Also, {@code junit4.TearDownTestCase} will.
   *
   * @throws Exception for any reason. {@code TearDownTestCase} ensures that any exception thrown
   *     will not interfere with other TearDown operations.
   */
  void tearDown() throws Exception;

                  actualOccupiedDepth.set(monitor.getOccupiedDepth());
                } catch (Throwable t) {
                  thrown.set(t);
                }
              }
            }));
    assertNull(thrown.get());
    assertEquals(expectedIsOccupied, actualIsOccupied.get());
    assertEquals(expectedIsOccupiedByCurrentThread, actualIsOccupiedByCurrentThread.get());

                  actualOccupiedDepth.set(monitor.getOccupiedDepth());
                } catch (Throwable t) {
                  thrown.set(t);
                }
              }
            }));
    assertNull(thrown.get());
    assertEquals(expectedIsOccupied, actualIsOccupied.get());
    assertEquals(expectedIsOccupiedByCurrentThread, actualIsOccupiedByCurrentThread.get());

        smbFileHandle.close(lastWriteTime);
        verify(smbFileHandle, times(1)).close(lastWriteTime);
    }

    /**
     * Test close(long) when a CIFSException is thrown.
     *
     * @throws CIFSException
     */
    @Test
    void testCloseWithLastWriteTime_throwsCIFSException() throws CIFSException {
        long lastWriteTime = System.currentTimeMillis();

     *
     * @param <REQ> The request type
     * @param <REP> The response type
     * @param req The request object used as the cache key
     * @param supplier The function to execute and cache the result
     * @return The result from the supplier (either fresh or cached)

    @Test
    void testSetOptionEndpointInvalidPipe() {
        String endpoint = "\\pipe\\unknown";
        DcerpcException thrown = assertThrows(DcerpcException.class, () -> {
            dcerpcBinding.setOption("endpoint", endpoint);
        }, "Should throw DcerpcException for unknown pipe endpoint.");

        assertTrue(thrown.getMessage().contains("Bad endpoint"), "Exception message should indicate a bad endpoint.");
    }

    @Test

                        throw new RuntimeException("non-critical error");
                    }, isFailure);
                    fail("Should have thrown exception");
                } catch (CIFSException e) {
                    // Expected - exception is thrown but not counted as failure
                }
            }

            // NOTE: Implementation behavior - custom predicate may not prevent all state changes

 * the License.
 */

package com.google.common.eventbus;

/**
 * Handler for exceptions thrown by event subscribers.
 *
 * @since 16.0
 */
public interface SubscriberExceptionHandler {
  /** Handles exceptions thrown by subscribers. */
  void handleException(Throwable exception, SubscriberExceptionContext context);

laceholder]").each(function(){this.__defaultValue=this.getAttribute("placeholder"),a(this).bind("focus",function(){this.value===this.__defaultValue&&(this.value="",a(this).removeClass("showing-placeholder"))}).bind("blur",function(){""===a.trim(this.value)&&(this.value=this.__defaultValue,a(this).addClass("showing-placeholder"))})})})};a.formUtils.$win.bind("validatorsLoaded formValidationSetup",function(b,c){c||(c=a("form")),e(c)}),a.formUtils.setupValidationUsingHTML5Attr=e}(a,window)});...

 * 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