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

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

    override fun timeout(): Timeout = timeout

    override fun read(

Lokhttp3/internal/http/RealInterceptorChain;
Lokhttp3/internal/http/RealResponseBody;
Lokhttp3/internal/http/RetryAndFollowUpInterceptor;
Lokhttp3/internal/http/StatusLine;
Lokhttp3/internal/http1/Http1ExchangeCodec$AbstractSource;
Lokhttp3/internal/http1/Http1ExchangeCodec$FixedLengthSource;
Lokhttp3/internal/http1/Http1ExchangeCodec;
Lokhttp3/internal/http2/ConnectionShutdownException;
Lokhttp3/internal/http2/ErrorCode;