    @Test
    void test() {

        Vertx vertx = Vertx.vertx();

        vertx.createNetServer()
                .connectHandler(socket -> {
                    socket.write("tes");
                    socket.write("ttest");
                })
                .listen(12311);

        VertxTcpClientProvider provider = new VertxTcpClientProvider(id -> Mono.empty(), vertx, new DefaultPayloadParserBuilder());

        TcpClientProperties properties = new TcpClientProperties();
        properties.setHost("127.0.0.1");
        properties.setPort(12311);
        properties.setParserType(PayloadParserType.FIXED_LENGTH);
        properties.setParserConfiguration(Collections.singletonMap("size", 4));
        properties.setOptions(new NetClientOptions());


        provider.createNetwork(properties)
                .subscribe()
                .map(TcpMessage::getPayload)
                .map(buf -> buf.toString(StandardCharsets.UTF_8))
                .take(2)
                .as(StepVerifier::create)
                .expectNext("test", "test")
                .verifyComplete();

    }