}
    }
    if (responseDone) {
      if (e != null) {
        call.eventListener.responseFailed(call, e)
      } else {
        call.eventListener.responseBodyEnd(call, bytesRead)
      }
    }
    return call.messageDone(
      exchange = this,
      requestDone = requestDone && !isSocket,
      responseDone = responseDone && !isSocket,
      socketSinkDone = requestDone && isSocket,

    var callDone = false
    withLock {
      if (
        requestDone && requestBodyOpen ||
        responseDone && responseBodyOpen ||
        socketSinkDone && socketSinkOpen ||
        socketSourceDone && socketSourceOpen
      ) {
        if (requestDone) requestBodyOpen = false
        if (responseDone) responseBodyOpen = false
        if (socketSinkDone) socketSinkOpen = false

	return
}

// DecodeMsg implements msgp.Decodable
func (z *ResponseCode) DecodeMsg(dc *msgp.Reader) (err error) {
	{
		var zb0001 uint8
		zb0001, err = dc.ReadUint8()
		if err != nil {
			err = msgp.WrapError(err)
			return
		}
		(*z) = ResponseCode(zb0001)
	}
	return
}

// EncodeMsg implements msgp.Encodable
func (z ResponseCode) EncodeMsg(en *msgp.Writer) (err error) {
	err = en.WriteUint8(uint8(z))

    shouldWriteToCache: Boolean,
    responseCode: Int,
    method: String = "GET",
  ) {
    var expectedResponseCode = responseCode
    val server = MockWebServer()
    val builder =
      MockResponse
        .Builder()
        .addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS))
        .addHeader("Expires: " + formatDate(1, TimeUnit.HOURS))
        .code(responseCode)
        .body("ABCDE")