*/
  @Throws(IOException::class)
  fun shutdown(statusCode: ErrorCode) {
    writer.withLock {
      val lastGoodStreamId: Int
      withLock {
        if (isShutdown) {
          return
        }
        isShutdown = true
        lastGoodStreamId = this.lastGoodStreamId
      }
      // TODO: propagate exception message into debugData.

    reader.nextFrame(
      requireSettings = false,
      object : BaseTestHandler() {
        override fun goAway(
          lastGoodStreamId: Int,
          errorCode: ErrorCode,
          debugData: ByteString,
        ) {
          assertThat(lastGoodStreamId).isEqualTo(expectedStreamId)
          assertThat(errorCode).isEqualTo(expectedError)
          assertThat(debugData.size).isEqualTo(0)
        }

      sink.writeInt(payload2)
      sink.flush()
    }
  }

  /**
   * Tell the peer to stop creating streams and that we last processed `lastGoodStreamId`, or zero
   * if no streams were processed.
   *
   * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed.
   * @param errorCode reason for closing the connection.

     * `ID > lastGoodStreamId` on a new connection.  In- flight streams with
     * `ID <= lastGoodStreamId` can only be replayed on a new connection if they are idempotent.
     *
     * @param lastGoodStreamId the last stream ID the peer processed before sending this message. If
     *     [lastGoodStreamId] is zero, the peer processed no frames.