delegate.addRelatedGroup(group);
    items.addAll(ImmutableList.copyOf(group));
    return this;
  }

  /** Run tests on equivalence methods, throwing a failure on an invalid test */
  @CanIgnoreReturnValue
  public EquivalenceTester<T> test() {
    for (int run = 0; run < REPETITIONS; run++) {
      testItems();
      delegate.test();
    }
    return this;
  }

    }

    @Override
    public void run() {
      if (future instanceof InternalFutureFailureAccess) {
        Throwable failure =
            InternalFutures.tryInternalFastPathGetFailure((InternalFutureFailureAccess) future);
        if (failure != null) {
          callback.onFailure(failure);
          return;
        }
      }
      V value;
      try {
        value = getDone(future);

    }

    /**
     * Deletes a request header setting by ID.
     *
     * @param id the ID of the request header setting to delete
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/reqheader/setting/{id}
    @Execute
    public JsonResponse<ApiResult> delete$setting(final String id) {
        reqHeaderService.getRequestHeader(id).ifPresent(entity -> {

    }

    /**
     * Deletes a web authentication setting by ID.
     *
     * @param id the ID of the web authentication setting to delete
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/webauth/setting/{id}
    @Execute
    public JsonResponse<ApiResult> delete$setting(final String id) {
        webAuthService.getWebAuthentication(id).ifPresent(entity -> {

        logger.info(getCurrentIndent() + ConsoleIcon.SUCCESS.getIcon(terminal) + " " + message);
    }

    /**
     * Logs an error with an X icon.
     */
    public void failure(String message) {
        logger.error(getCurrentIndent() + ConsoleIcon.ERROR.getIcon(terminal) + " " + message);
    }

    /**
     * Logs a warning with a warning icon.
     */

                alternativeChannel.getTransport().send(op);
            } catch (Exception e) {
                log.error("Failed to redistribute operation", e);
                // Notify waiting threads of failure
                op.notifyError(e);
            }
        }
    }
    
    private void scheduleRecovery(ChannelInfo channel, FailoverState state) {
        state.incrementRetry();
        

        verify(mockRpc).register(any(WitnessRegisterRequest.class));

        client.close();
    }

    @Test
    void testFailedRegistration() throws Exception {
        // Setup mock RPC response for failure
        WitnessRegisterResponse mockResponse = mock(WitnessRegisterResponse.class);
        when(mockResponse.isSuccess()).thenReturn(false);
        when(mockResponse.getError()).thenReturn("Registration failed");

        for (int i = 0; i < 8; i++) {
            if (signature[i] != data[offset + SmbConstants.SIGNATURE_OFFSET + i]) {
                if (LogStream.level >= 2) {
                    log.println("signature verification failure");
                    Hexdump.hexdump(log, signature, 0, 8);
                    Hexdump.hexdump(log, data, offset + SmbConstants.SIGNATURE_OFFSET, 8);
                }
                return response.verifyFailed = true;

 *     .build();
 * client.newCall(request).execute();
 * ```
 *
 * As expected, this fails with a certificate pinning exception:
 *
 * ```java
 * javax.net.ssl.SSLPeerUnverifiedException: Certificate pinning failure!
 * Peer certificate chain:
 *     sha256/afwiKY3RxoMmLkuRW1l7QsPZTJPwDS2pdDROQjXw8ig=: CN=publicobject.com, OU=PositiveSSL
 *     sha256/klO23nT2ehFDXCfx3eHTDRESMz3asj1muO+4aIdjiuY=: CN=COMODO RSA Secure Server CA

          </excludePackageNames>
          <!-- Ignore some tags that are found in Java 11 sources but not recognized... under -source 8, I think it was? I can no longer reproduce the failure. -->
          <tags>
            <tag>
              <name>apiNote</name>
              <placement>X</placement>
            </tag>
            <tag>
              <name>implNote</name>