Skip to content

Commit

Permalink
Remove connections limitation in the test as not needed
Browse files Browse the repository at this point in the history
  • Loading branch information
violetagg committed Sep 8, 2017
1 parent 723718a commit 9347771
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ private void doTestPrefetchSize(int writeBufferLowWaterMark, int writeBufferHigh
}

@Test
public void testChannelInactiveThrowsAbortedException() throws Exception {
public void testChannelInactiveThrowsIOException() throws Exception {
ExecutorService threadPool = Executors.newCachedThreadPool();

int abortServerPort = SocketUtils.findAvailableTcpPort();
Expand All @@ -108,8 +108,7 @@ public void testChannelInactiveThrowsAbortedException() throws Exception {

Mono<HttpClientResponse> response =
HttpClient.create(ops -> ops.host("localhost")
.port(abortServerPort)
.poolResources(PoolResources.fixed("http", 1)))
.port(abortServerPort))
.get("/", req -> req.sendString(Flux.just("a", "b", "c")));

StepVerifier.create(response)
Expand Down

0 comments on commit 9347771

Please sign in to comment.