Better use of AtomicBoolean (#1210)

nats-io · Aug 19, 2024 · a6ef493 · a6ef493
1 parent ba73b87
commit a6ef493
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsConnectionWriter.java b/src/main/java/io/nats/client/impl/NatsConnectionWriter.java
@@ -200,8 +200,7 @@ public void run() {
                     sendMessageBatch(msg, dataPort, stats);
                 }
 
-                if (flushBuffer.get()) {
-                    flushBuffer.set(false);
+                if (flushBuffer.getAndSet(false)) {
                     dataPort.flush();
                 }
             }