* Object#hashCode} and {@link Object#toString}. For example:
 *
 * <pre>
 * class Unsupported extends AbstractInvocationHandler {
 *   protected Object handleInvocation(Object proxy, Method method, Object[] args) {
 *     throw new UnsupportedOperationException();
 *   }
 * }
 *
 * CharSequence unsupported = Reflection.newProxy(CharSequence.class, new Unsupported());
 * </pre>
 *
 * @author Ben Yu
 * @since 12.0
 */

        };
    addCallback(f, callback, directExecutor());
  }

  private class CountingSameThreadExecutor implements Executor {
    int runCount = 0;

    @Override
    public void execute(Runnable command) {
      command.run();
      runCount++;
    }
  }

  private final class MockCallback implements FutureCallback<String> {
    @Nullable private String value = null;

                .singleton("urlFilter", UrlFilterImpl.class)//
                .singleton("dataService", DataServiceImpl.class);
        urlFilter = container.getComponent("urlFilter");
        dataHelper = container.getComponent("dataHelper");
    }

    public void test_addInclude1() {
        assertEquals(0, urlFilter.cachedIncludeSet.size());
        assertEquals(0, urlFilter.cachedExcludeSet.size());

import org.codelibs.fess.Constants;
import org.dbflute.optional.OptionalThing;

/**
 * Utility class for managing field configurations with parameter mappings.
 * This class provides functionality to retrieve and manage field-specific configurations
 * from a parameter map.
 */
public class FieldConfigs {

    /**
     * Map containing field names as keys and their corresponding configuration values as values.

import jakarta.servlet.http.HttpSession;

/**
 * The login action.
 */
public class LoginAction extends FessLoginAction {

    /**
     * Default constructor.
     */
    public LoginAction() {
        super();
    }

    private static final Logger logger = LogManager.getLogger(LoginAction.class);

    private static final String INVALID_OLD_PASSWORD = "LoginAction.invalidOldPassword";

    assertThrows(IllegalArgumentException.class, () -> resetMap(entries));
  }

  @MapFeature.Require(REJECTS_DUPLICATES_AT_CREATION)
  @CollectionSize.Require(absent = {ZERO, ONE})
  public void testCreateWithDuplicates_nonNullDuplicatesRejected() {
    Entry<K, V>[] entries = getEntriesMultipleNonNullKeys();
    assertThrows(IllegalArgumentException.class, () -> resetMap(entries));
  }

import org.dbflute.cbean.ConditionQuery;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.index.query.QueryBuilder;

/**
 * @author ESFlute (using FreeGen)
 */
public class BsUserCB extends EsAbstractConditionBean {

    // ===================================================================================
    //                                                                           Attribute

  /** Follow-ups for failed plans and plans that lost a race. */
  val deferredPlans: ArrayDeque<Plan>

  fun isCanceled(): Boolean

  /** Returns a plan to attempt. */
  @Throws(IOException::class)
  fun plan(): Plan

  /**
   * Returns true if there's more route plans to try.
   *
   * @param failedConnection an optional connection that was resulted in a failure. If the failure

import okhttp3.Handshake;
import okhttp3.HttpUrl;
import okhttp3.OkHttpClient;
import okhttp3.Protocol;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;

public final class PrintEvents {
  private final OkHttpClient client = new OkHttpClient.Builder()
      .eventListenerFactory(PrintingEventListener.FACTORY)
      .build();

  public void run() throws Exception {

import java.util.ArrayList;
import java.util.List;

/**
 * Represents a witness notification received from the witness service.
 * Contains event information, resource details, and IP address changes.
 */
public class WitnessNotification {
    private WitnessEventType eventType;
    private long timestamp;
    private String resourceName;
    private final List<WitnessIPAddress> newIPAddresses;