val request = server.takeRequest()
    assertThat(request.requestLine).isEqualTo("POST /foo HTTP/2")
    assertArrayEquals(postBytes, request.body?.toByteArray())
    assertThat(request.headers["Content-Length"]!!.toInt()).isEqualTo(postBytes.size)
  }

  @ParameterizedTest
  @ArgumentsSource(ProtocolParamProvider::class)
  fun closeAfterFlush(protocol: Protocol) {
    setUp(protocol)
    val postBytes = "FGHIJ".toByteArray()

      limit: Int,
    ): Int =
      try {
        // Canonicalize the port string to skip '\n' etc.
        val portString = input.canonicalize(pos = pos, limit = limit, encodeSet = "")
        val i = portString.toInt()
        if (i in 1..65535) i else -1
      } catch (_: NumberFormatException) {
        -1 // Invalid port.
      }
  }

  companion object {

    internal var readTimeout = 10_000
    internal var writeTimeout = 10_000
    internal var pingInterval = 0
    internal var webSocketCloseTimeout = RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS.toInt()
    internal var minWebSocketMessageToCompress = RealWebSocket.DEFAULT_MINIMUM_DEFLATE_SIZE
    internal var routeDatabase: RouteDatabase? = null
    internal var taskRunner: TaskRunner? = null