Header(RESPONSE_STATUS, "204"),
      Header(RESPONSE_STATUS, "206"),
      Header(RESPONSE_STATUS, "304"),
      Header(RESPONSE_STATUS, "400"),
      Header(RESPONSE_STATUS, "404"),
      Header(RESPONSE_STATUS, "500"),
      Header("accept-charset", ""),
      Header("accept-encoding", "gzip, deflate"),
      Header("accept-language", ""),
      Header("accept-ranges", ""),
      Header("accept", ""),

Sebastián Ramírez <******@****.***> 1774026338 +0100

Yuri Schimke <******@****.***> 1746875714 +0100

    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)

    // Give the server time to enact the socket policy if it's one that could happen after the
    // client has received the response.
    Thread.sleep(500)
    val response2 = getResponse(newRequest("/b"))
    response1.body
      .source()
      .timeout()
      .timeout(100, TimeUnit.MILLISECONDS)
    assertContent("This comes after a busted connection", response2)

cpovirk <******@****.***> 1773337518 -0700

cpovirk <******@****.***> 1773337518 -0700

            final QueryBuilder queryBuilder) {
        try {
            SearchResponse response = client.prepareSearch(index)
                    .setQuery(queryBuilder)
                    .setSize(500)
                    .setScroll(settings.getScrollTimeout())
                    .execute()
                    .actionGet(settings.getSearchTimeout());
            String scrollId = response.getScrollId();

            } catch (Exception e) {
                caughtException.set(e);
            }
        }

        // Wait for tasks to complete
        Thread.sleep(500);

        // No interference should occur (just verify no critical errors)
        assertTrue("Multiple scheduled tasks should not interfere with each other", true);
    }

    /**

Shinsuke Sugaya <******@****.***> 1755149504 +0900

Shinsuke Sugaya <******@****.***> 1771833824 +0900