});
Assert.assertTrue(contentLatch.await(5, TimeUnit.SECONDS));
Assert.assertFalse(completeLatch.await(1, TimeUnit.SECONDS));
callbackRef.get().succeeded();
Assert.assertTrue(completeLatch.await(5, TimeUnit.SECONDS));
<BUG>}
private void consume(InputStream input) throws IOException

{
while (true)
{
if (input.read() < 0)
break;</BUG>
}

});
client.setConnectBlocking(true);
ContentResponse response = client.GET(scheme + "://localhost:" + connector.getLocalPort());
Assert.assertNotNull(response);
Assert.assertEquals(200, response.getStatus());
byte[] content = response.getContent();
Assert.assertArrayEquals(data, content);
}
@Test
public void test_GET_WithParameters_ResponseWithContent() throws Exception
