*/
    public ActionResponseCredential(final Supplier<ActionResponse> action) {
        this.action = action;
    }

    /**
     * Execute the action.
     * @return The action response.
     */
    public ActionResponse execute() {
        return action.get();
    }

    //                                                                      Search Execute
    //                                                                      ==============
    /**
     * The index page.
     * @param form The search form.
     * @return The HTML response.
     */
    @Execute
    public HtmlResponse index(final SearchForm form) {
        return search(form);
    }

    /**

    //                                                                      Search Execute
    //                                                                      ==============
    /**
     * Displays the not found error page.
     *
     * @param form the error form containing error information
     * @return HTML response for the not found error page
     */
    @Execute
    public HtmlResponse index(final ErrorForm form) {

        .body("I'm not even supposed to be here today.")
        .build(),
    )
    val call = client.newCall(Request(url = server.url("/")))
    assertFailsWith<IOException> {
      call.execute()
    }
  }

  /** Use a header that exceeds the limits on its own. */
  @Test
  fun largeResponseHeader() {
    server.enqueue(
      MockResponse
        .Builder()

        String result = suggestJob.execute();

        assertTrue(result.contains("Session Id: " + existingSessionId));
        assertEquals(existingSessionId, suggestJob.sessionId);
    }

    // Test execute method with job executor shutdown listener
    @Test
    public void test_execute_withJobExecutor() {
        createRequiredDirectories();

      writer.data(outFinished && byteCount == 0L, streamId, buffer, toWrite)
    }
  }

  internal fun writeSynResetLater(
    streamId: Int,
    errorCode: ErrorCode,
  ) {
    writerQueue.execute("$connectionName[$streamId] writeSynReset") {
      try {
        writeSynReset(streamId, errorCode)
      } catch (e: IOException) {
        failConnection(e)
      }
    }
  }

        transaction.setSetupCount(0);

        // Execute for primary transaction
        int primaryBytes = transaction.writeParameterWordsWireFormat(dst, 0);

        // The return value should be the number of bytes written
        // For primary NT transaction: should be at least 38 bytes
        assertTrue(primaryBytes >= 38);

        // Execute for secondary transaction

    //                                                                      ==============
    /**
     * Serves a thumbnail image for the specified document.
     *
     * @param form the thumbnail request form containing document ID and query parameters
     * @return ActionResponse containing the thumbnail image or 404 if not found
     */
    @Execute

        .newClientBuilder()
        .sslSocketFactory(clientCertificates.sslSocketFactory(), clientCertificates.trustManager)
        .build()

    val call = client.newCall(Request(server.url("/")))
    val response = call.execute()
    assertThat(response.code).isEqualTo(200)
    assertThat(response.handshake!!.cipherSuite).isNotNull()
    assertThat(response.handshake!!.tlsVersion).isNotNull()

   * Callable}.
   *
   * @param callable the callable task
   * @since 10.0
   */
  public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) {
    return new ListenableFutureTask<>(callable);
  }

  /**
   * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code