public void testRuntimeException_doesNotStopExecution() {

    AtomicInteger numCalls = new AtomicInteger();

    Runnable runMe =
        () -> {
          numCalls.incrementAndGet();
          throw new RuntimeException("FAKE EXCEPTION!");
        };

    e.execute(runMe);
    e.execute(runMe);
    fakePool.runAll();

    assertEquals(2, numCalls.get());
  }

    try {
      super.testKeySetRemoveAllNullFromEmpty();
    } catch (RuntimeException tolerated) {
      // GWT's HashMap.keySet().removeAll(null) doesn't throws NPE.
    }
  }

  @Override
  public void testEntrySetRemoveAllNullFromEmpty() {
    try {
      super.testEntrySetRemoveAllNullFromEmpty();
    } catch (RuntimeException tolerated) {
      // GWT's HashMap.entrySet().removeAll(null) doesn't throws NPE.

          .put(NullPointerException.class, e -> e instanceof NullPointerException)
          .put(NumberFormatException.class, e -> e instanceof NumberFormatException)
          .put(RuntimeException.class, e -> e instanceof RuntimeException)
          .put(SomeCheckedException.class, e -> e instanceof SomeCheckedException)
          .put(SomeError.class, e -> e instanceof SomeError)

            exception = t;
          } else {
            exception.addSuppressed(t);
          }
        }
      }
    }
    if (exception != null) {
      throwIfUnchecked(exception);
      throw new RuntimeException("failure during tearDown", exception);
    }
  }

            exception = t;
          } else {
            exception.addSuppressed(t);
          }
        }
      }
    }
    if (exception != null) {
      throwIfUnchecked(exception);
      throw new RuntimeException("failure during tearDown", exception);
    }
  }

          .put(NullPointerException.class, e -> e instanceof NullPointerException)
          .put(NumberFormatException.class, e -> e instanceof NumberFormatException)
          .put(RuntimeException.class, e -> e instanceof RuntimeException)
          .put(SomeCheckedException.class, e -> e instanceof SomeCheckedException)
          .put(SomeError.class, e -> e instanceof SomeError)

                assertTrue(true, "Sign operation after close should either throw exception or handle gracefully");
            } catch (RuntimeException e) {
                // Accept runtime exceptions that might be thrown due to closed state
                assertTrue(e.getMessage() != null, "Exception should have a message: " + e.getClass().getSimpleName());
            }

/**
 * CleanArgument
 */
@Deprecated
public class CleanArgument {
    public static String[] cleanArgs(String[] args) {
        try {
            return doCleanArgs(args);
        } catch (RuntimeException e) {
            for (String a : args) {
                System.out.println("Arg: '" + a + "'");
            }
            throw e;
        }
    }

    private static String[] doCleanArgs(String[] args) {

  @Test
  fun throwingOnOpenFailsImmediately() {
    webServer.enqueue(
      MockResponse
        .Builder()
        .webSocketUpgrade(serverListener)
        .build(),
    )
    val e = RuntimeException()
    clientListener.setNextEventDelegate(
      object : WebSocketListener() {
        override fun onOpen(
          webSocket: WebSocket,
          response: Response,
        ): Unit = throw e
      },

    assertEquals(6, (int) future.get());
  }

  public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
    Runnable runnable =
        () -> {
          throw new RuntimeException("Oh no!");
        };

    Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
    assertThrows(ExecutionException.class, future::get);
  }