so2.handler(buffer -> {
fail();
});
so2.closeHandler(v -> {
paused.set(false);
socketStream.resume();
client.connect(1234, "localhost", ar3 -> {
assertTrue(ar3.succeeded());
NetSocket so3 = ar3.result();
Buffer buffer = Buffer.buffer();
so3.handler(buffer::appendBuffer);