}

    // Custom Query class for testing unknown query type
    private static class CustomQuery extends Query {
        @Override
        public String toString(String field) {
            return "CustomQuery";
        }

        @Override
        public boolean equals(Object obj) {
            return obj != null && getClass() == obj.getClass();
        }

      val rewrittenResponse =
        originalResponse
          .newBuilder()
          .body(responseBodyData.toResponseBody())
          .build()
      assertThat(rewrittenResponse.body.string()).isEqualTo("Hello")
      assertThat(rewrittenResponse.trailers()).isEqualTo(headersOf("t1", "v1"))
    }
  }

  /**
   * We had a bug where a custom `ResponseBody` interacted poorly with `Response.trailers()`.

  ) = logEvent(ProxySelectEnd(System.nanoTime(), call, url, proxies))

  override fun dnsStart(
    call: Call,
    domainName: String,
  ) = logEvent(DnsStart(System.nanoTime(), call, domainName))

  override fun dnsEnd(
    call: Call,
    domainName: String,
    inetAddressList: List<InetAddress>,
  ) = logEvent(DnsEnd(System.nanoTime(), call, domainName, inetAddressList))

  override fun connectStart(

    private var intermediates: Array<X509Certificate>? = null
    private val trustedCertificates = mutableListOf<X509Certificate>()
    private val insecureHosts = mutableListOf<String>()

    /**
     * Configure the certificate chain to use when being authenticated. The first certificate is
     * the held certificate, further certificates are included in the handshake so the peer can

    }

    /**
     * Record a write operation error
     */
    public void recordWriteError() {
        recordError();
    }

    @Override
    public String toString() {
        return String.format(
                "RdmaStatistics[reads=%d, writes=%d, sends=%d, receives=%d, "
                        + "bytes=%d, errors=%d, errorRate=%.3f, activeConnections=%d, activeMemRegions=%d]",

val triggerExcludes =
    """
    -:.idea
    -:.github
    -:.teamcity
    -:platforms/documentation/docs/src/docs/release
    """.trimIndent()

fun branchesFilterExcluding(vararg excludedBranch: String) =
    """
+:*
${excludedBranch.joinToString("\n") { "-:$it" }}

@GwtCompatible
@NullUnmarked
public class EscapersTest extends TestCase {
  public void testNullEscaper() throws IOException {
    Escaper escaper = Escapers.nullEscaper();
    EscaperAsserts.assertBasic(escaper);
    String s = "\0\n\t\\az09~\uD800\uDC00\uFFFF";
    assertWithMessage("null escaper should have no effect").that(escaper.escape(s)).isEqualTo(s);
  }

  public void testBuilderInitialStateNoReplacement() {

        // handled special in SmbTransport.doRecv()
        return 0;
    }

    @Override
    public String toString() {
        return ("SmbComReadAndXResponse[" + super.toString() + ",dataCompactionMode=" + this.dataCompactionMode + ",dataLength="
                + this.dataLength + ",dataOffset=" + this.dataOffset + "]");
    }

     * @param outputCallback the callback function to handle process output lines
     */
    public JobProcess(final Process process, final int bufferSize, final Consumer<String> outputCallback) {
        this.process = process;
        inputStreamThread = new InputStreamThread(process.getInputStream(), Constants.CHARSET_UTF_8, bufferSize, outputCallback);
    }

    /**

    }
    return false;
  }

  @Override
  public int hashCode() {
    return presentFeatures.hashCode() * 31 + absentFeatures.hashCode();
  }

  @Override
  public String toString() {
    return "{TesterRequirements: present=" + presentFeatures + ", absent=" + absentFeatures + "}";
  }

  @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;