return call.messageDone(
      exchange = this,
      requestDone = requestDone && !isSocket,
      responseDone = responseDone && !isSocket,
      socketSinkDone = requestDone && isSocket,
      socketSourceDone = responseDone && isSocket,
      e = e,
    )
  }

  fun noRequestBody() {
    call.messageDone(
      exchange = this,
      requestDone = true,
      e = null,
    )
  }

    var allStreamsDone = false
    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