* Stores a document in the search index with the specified parameters and data.
     *
     * @param paramMap the data store parameters containing configuration and metadata
     * @param dataMap the document data to be indexed as key-value pairs
     */
    void store(DataStoreParams paramMap, Map<String, Object> dataMap);

    /**
     * Returns the total number of documents processed by this callback.
     *
     * @return the document count

  public int hashCode() {
    K k = getKey();
    V v = getValue();
    return ((k == null) ? 0 : k.hashCode()) ^ ((v == null) ? 0 : v.hashCode());
  }

  /** Returns a string representation of the form {@code {key}={value}}. */
  @Override
  public String toString() {
    return getKey() + "=" + getValue();
  }

  public int hashCode() {
    K k = getKey();
    V v = getValue();
    return ((k == null) ? 0 : k.hashCode()) ^ ((v == null) ? 0 : v.hashCode());
  }

  /** Returns a string representation of the form {@code {key}={value}}. */
  @Override
  public String toString() {
    return getKey() + "=" + getValue();
  }

        return doGetConditionQuery();
    }

    // ===================================================================================
    //                                                                         Primary Key
    //                                                                         ===========
    public BoostDocumentRuleCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsBoostDocumentRuleCB cb = this;

        return doGetConditionQuery();
    }

    // ===================================================================================
    //                                                                         Primary Key
    //                                                                         ===========
    public FileAuthenticationCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsFileAuthenticationCB cb = this;

        return doGetConditionQuery();
    }

    // ===================================================================================
    //                                                                         Primary Key
    //                                                                         ===========
    public KeyMatchCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsKeyMatchCB cb = this;

        return doGetConditionQuery();
    }

    // ===================================================================================
    //                                                                         Primary Key
    //                                                                         ===========
    public LabelTypeCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsLabelTypeCB cb = this;

        return doGetConditionQuery();
    }

    // ===================================================================================
    //                                                                         Primary Key
    //                                                                         ===========
    public RequestHeaderCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsRequestHeaderCB cb = this;

  encodedValues: List<String>,
) : RequestBody() {
  private val encodedNames: List<String> = encodedNames.toImmutableList()
  private val encodedValues: List<String> = encodedValues.toImmutableList()

  /** The number of key-value pairs in this form-encoded body. */
  @get:JvmName("size")
  val size: Int
    get() = encodedNames.size

  @JvmName("-deprecated_size")
  @Deprecated(
    message = "moved to val",

  private fun upgradeResponse(request: RecordedRequest): MockResponse.Builder {
    val key = request.headers["Sec-WebSocket-Key"]
    return MockResponse
      .Builder()
      .status("HTTP/1.1 101 Switching Protocols")
      .setHeader("Connection", "Upgrade")
      .setHeader("Upgrade", "websocket")
      .setHeader("Sec-WebSocket-Accept", acceptHeader(key!!))
  }

  private fun websocketScheme(scheme: String) {