// Verify getResult returns appropriate exception
            DcerpcException exception = bind.getResult();
            assertNotNull(exception, "Should return exception for error result");
            assertEquals("DCERPC_BIND_ERR_PROPOSED_TRANSFER_SYNTAXES_NOT_SUPPORTED", exception.getMessage(),
                    "Should return correct error message");
        }

        @Test

    /**
     * @throws Exception
     */
    public void testEncode() throws Exception {
        assertEquals("1", ENCODED_DATA, Base64Util.encode(BINARY_DATA));
        System.out.println(Base64Util.encode(new byte[] { 'a', 'b', 'c' }));
    }

    /**
     * @throws Exception
     */
    public void testDecode() throws Exception {
        final byte[] decodedData = Base64Util.decode(ENCODED_DATA);

     * @throws Exception
     */
    public void testGetActualKeyClassOfMap() throws Exception {
        final Map<TypeVariable<?>, Type> map = GenericsUtil.getTypeVariableMap(Hoge.class);
        final Method method = Hoge.class.getMethod("map");
        assertThat(GenericsUtil.getActualKeyClassOfMap(method.getGenericReturnType(), map), is(sameClass(String.class)));
    }

    /**
     * @throws Exception
     */

        }
    }

    /**
     * Searcher that throws an exception during search.
     */
    static class ExceptionThrowingSearcher extends RankFusionSearcher {
        private final RuntimeException exception;

        ExceptionThrowingSearcher(RuntimeException exception) {
            this.exception = exception;
        }

        @Override

  public void testFailOnExceptionFromRun() throws Exception {
    TestService service = new TestService();
    service.runException = new Exception();
    service.startAsync().awaitRunning();
    service.runFirstBarrier.await();
    service.runSecondBarrier.await();
    assertThrows(CancellationException.class, () -> future.get());
    // An execution exception holds a runtime exception (from throwables.propagate) that holds our

  public void testFailOnExceptionFromRun() throws Exception {
    TestService service = new TestService();
    service.runException = new Exception();
    service.startAsync().awaitRunning();
    service.runFirstBarrier.await();
    service.runSecondBarrier.await();
    assertThrows(CancellationException.class, () -> future.get());
    // An execution exception holds a runtime exception (from throwables.propagate) that holds our

        Exception exception = assertThrows(Exception.class, () -> {
            new KerberosRelevantAuthData(emptyToken, keys);
        }, "An exception should be thrown for an empty token.");

        // The exception could be PACDecodingException or NullPointerException
        assertTrue(exception instanceof PACDecodingException || exception instanceof NullPointerException,

    private final MojoExecution mojoExecution;

    private final Exception exception;

    DefaultExecutionEvent(Type type, MavenSession session, MojoExecution mojoExecution, Exception exception) {
        this.type = type;
        this.session = session;
        this.mojoExecution = mojoExecution;
        this.exception = exception;
    }

    @Override
    public Type getType() {
        return type;
    }

         * @param request the request data
         * @param exceptionList the list of exceptions that occurred during retries
         */
        void onRequestEnd(FaultTolerantClient client, RequestData request, List<Exception> exceptionList);

        /**
         * Called when an exception occurs during a request attempt.
         *
         * @param client the fault-tolerant client

/**
 * Classes and futures used in {@link FuturesGetCheckedTest} and {@link FuturesGetUncheckedTest}.
 */
@GwtCompatible
@NullUnmarked
final class FuturesGetCheckedInputs {
  static final Exception CHECKED_EXCEPTION = new Exception("mymessage");
  static final Future<String> FAILED_FUTURE_CHECKED_EXCEPTION =
      immediateFailedFuture(CHECKED_EXCEPTION);
  static final RuntimeException UNCHECKED_EXCEPTION = new RuntimeException("mymessage");