|
11 | 11 |
|
12 | 12 | package io.vertx.core.http; |
13 | 13 |
|
| 14 | +import io.netty.buffer.ByteBufUtil; |
14 | 15 | import io.netty.channel.ConnectTimeoutException; |
15 | 16 | import io.netty.handler.codec.compression.DecompressionException; |
16 | 17 | import io.netty.handler.codec.http.HttpHeaderNames; |
@@ -5179,14 +5180,17 @@ protected void testHttpConnect(RequestOptions options, int sc) { |
5179 | 5180 | Buffer buffer = TestUtils.randomBuffer(128); |
5180 | 5181 | Buffer received = Buffer.buffer(); |
5181 | 5182 | CompletableFuture<Void> closeSocket = new CompletableFuture<>(); |
5182 | | - vertx.createNetServer(new NetServerOptions().setPort(1235).setHost("localhost")).connectHandler(socket -> { |
| 5183 | + // Declare netClient in the main thread to avoid having it randomly garbage collected just after it created the connection |
| 5184 | + NetClient netClient = vertx.createNetClient(new NetClientOptions()); |
| 5185 | + |
| 5186 | + vertx.createNetServer(new NetServerOptions().setPort(0).setHost("localhost")).connectHandler(socket -> { |
5183 | 5187 | socket.handler(socket::write); |
5184 | 5188 | closeSocket.thenAccept(v -> { |
5185 | 5189 | socket.close(); |
5186 | 5190 | }); |
5187 | 5191 | }).listen(onSuccess(netServer -> { |
5188 | 5192 | server.requestHandler(req -> { |
5189 | | - vertx.createNetClient(new NetClientOptions()).connect(1235, "localhost", onSuccess(dst -> { |
| 5193 | + netClient.connect(netServer.actualPort(), "localhost", onSuccess(dst -> { |
5190 | 5194 |
|
5191 | 5195 | req.response().setStatusCode(sc); |
5192 | 5196 | req.response().setStatusMessage("Connection established"); |
@@ -5217,7 +5221,7 @@ protected void testHttpConnect(RequestOptions options, int sc) { |
5217 | 5221 | } |
5218 | 5222 | }); |
5219 | 5223 | socket.closeHandler(v -> { |
5220 | | - assertEquals(buffer, received); |
| 5224 | + assertEquals(ByteBufUtil.hexDump(buffer.getBytes()), ByteBufUtil.hexDump(received.getBytes())); |
5221 | 5225 | testComplete(); |
5222 | 5226 | }); |
5223 | 5227 | socket.write(buffer); |
|
0 commit comments