fail<Any>()
    } catch (expected: ConnectException) {
    }
  }

  @Test
  fun shutdownWhileBlockedDispatching() {
    // Enqueue a request that'll cause MockWebServer to hang on QueueDispatcher.dispatch().
    val connection = server.url("/").toUrl().openConnection() as HttpURLConnection
    connection.setReadTimeout(500)
    try {
      connection.getResponseCode()
      fail<Any>()

    }
    server.url("/b").toUrl().openConnection().getInputStream() // Should succeed.
  }

  @Test
  fun clearDispatcherQueue() {
    server.enqueue(MockResponse(body = "A"))
    (server.dispatcher as QueueDispatcher).clear()
    server.enqueue(MockResponse(body = "B"))
    val inputStream = server.url("/a").toUrl().openConnection().getInputStream()
    assertThat(inputStream!!.read()).isEqualTo('B'.code)
  }

  /**