### Question:
VertxTcpClientProvider implements NetworkProvider<TcpClientProperties> { @Nonnull @Override public VertxTcpClient createNetwork(@Nonnull TcpClientProperties properties) { VertxTcpClient client = new VertxTcpClient(properties.getId()); initClient(client, properties); return client; } VertxTcpClientProvider(CertificateManager certificateManager, Vertx vertx, PayloadParserBuilder payloadParserBuilder); @Nonnull @Override NetworkType getType(); @Nonnull @Override VertxTcpClient createNetwork(@Nonnull TcpClientProperties properties); @Override void reload(@Nonnull Network network, @Nonnull TcpClientProperties properties); void initClient(VertxTcpClient client, TcpClientProperties properties); @Nullable @Override ConfigMetadata getConfigMetadata(); @Nonnull @Override Mono<TcpClientProperties> createConfig(@Nonnull NetworkProperties properties);  }### Answer:
@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(); }