private val protocol: Protocol,
  ) : Http2Connection.Listener() {
    private val nextExchangeIndex = AtomicInteger()

    @Throws(IOException::class)
    override fun onStream(stream: Http2Stream) {
      val peek = dispatcher.peek()
      if (handleSocketEffect(peek.onRequestStart, socket, stream)) {
        dispatchBookkeepingRequest(
          connectionIndex = connectionIndex,

    val maxConcurrentStreamsUpdated = CountDownLatch(1)
    val maxConcurrentStreams = AtomicInteger()
    val listener: Http2Connection.Listener =
      object : Http2Connection.Listener() {
        override fun onStream(stream: Http2Stream): Unit = throw AssertionError()

        override fun onSettings(
          connection: Http2Connection,
          settings: Settings,
        ) {