if (closed) return
      closed = true
      socket.sink.writeUtf8("0\r\n\r\n")
      detachTimeout(timeout)
      state = STATE_READ_RESPONSE_HEADERS
    }
  }

  private abstract inner class AbstractSource(
    val url: HttpUrl,
  ) : Source {
    protected val timeout = ForwardingTimeout(socket.source.timeout())
    protected var closed: Boolean = false

    override fun timeout(): Timeout = timeout