diff --git a/src/test/java/io/vertx/core/http/HttpTest.java b/src/test/java/io/vertx/core/http/HttpTest.java index c9e540cfe9a..a92a8fea097 100644 --- a/src/test/java/io/vertx/core/http/HttpTest.java +++ b/src/test/java/io/vertx/core/http/HttpTest.java @@ -11,15 +11,11 @@ package io.vertx.core.http; -import io.netty.channel.ChannelFuture; -import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ConnectTimeoutException; import io.netty.handler.codec.compression.DecompressionException; import io.netty.handler.codec.http.HttpHeaderNames; import io.netty.handler.codec.http.HttpResponseStatus; -import io.netty.handler.codec.http2.Http2EventAdapter; import io.netty.handler.codec.http2.Http2Exception; -import io.netty.handler.codec.http2.Http2Headers; import io.vertx.codegen.annotations.Nullable; import io.vertx.core.AbstractVerticle; import io.vertx.core.AsyncResult; @@ -34,7 +30,6 @@ import io.vertx.core.VertxOptions; import io.vertx.core.buffer.Buffer; import io.vertx.core.dns.AddressResolverOptions; -import io.vertx.core.http.Http2ServerTest.TestClient; import io.vertx.core.http.impl.HttpServerRequestInternal; import io.vertx.core.http.impl.ServerCookie; import io.vertx.core.http.impl.headers.HeadersMultiMap; @@ -55,7 +50,6 @@ import io.vertx.test.netty.TestLoggerFactory; import io.vertx.test.proxy.HAProxy; import org.junit.Assume; -import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; @@ -6826,8 +6820,9 @@ public void shouldThrowISEIfSendingResponseFromHeadersEndHandler() throws Except ); startServer(testAddress); client.request(requestOptions) - .compose(HttpClientRequest::send) - .compose(HttpClientResponse::end) + .compose(req -> req.send() + .andThen(onSuccess(resp -> assertEquals(200, resp.statusCode()))) + .compose(HttpClientResponse::end)) .onComplete(onSuccess(nothing -> complete())); await(); }