diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java index 9f2476840..2eb65eeca 100644 --- a/src/main/java/io/nats/client/impl/NatsConnection.java +++ b/src/main/java/io/nats/client/impl/NatsConnection.java @@ -1323,7 +1323,6 @@ CompletableFuture requestFutureInternal(String subject, Headers headers } publishInternal(subject, responseInbox, headers, data, validateSubRep); - writer.flushBuffer(); statistics.incrementRequestsSent(); return future;