assertFailsWith<StreamResetException> {
      call.execute()
    }.also { expected ->
      assertThat(expected.errorCode).isEqualTo(errorCode)
    }
  }

  @Test
  fun recoverFromConnectionNoNewStreamsOnFollowUp() {
    server.enqueue(MockResponse(code = 401))
    server.enqueue(
      MockResponse
        .Builder()
        .onRequestStart(CloseStream(ErrorCode.INTERNAL_ERROR.httpCode))