this.errorCode = errorCode
      this.errorException = errorException
      condition.signalAll()
      if (source.finished && sink.finished) {
        return false
      }
    }
    connection.removeStream(id)
    return true
  }

  @Throws(IOException::class)
  fun receiveData(
    source: BufferedSource,
    length: Int,
  ) {
    lock.assertNotHeld()