trying to stop the writer as soon as it's known that there is a communication issue

Author: scottf

src/main/java/io/nats/client/impl/NatsConnection.java

@@ -292,16 +292,7 @@ public void forceReconnect(ForceReconnectOptions options) throws IOException, In
     }
 
     void forceReconnectImpl(@NonNull ForceReconnectOptions frOpts) throws InterruptedException {
-        if (frOpts.getFlushWait() != null) {
-            try {
-                flush(frOpts.getFlushWait());
-            }
-            catch (TimeoutException e) {
-                // Ignored. Manual test demonstrates that if the connection is dropped
-                // in the middle of the flush, the most likely reason for a TimeoutException,
-                // the socket is closed.
-            }
-        }
+        writer.stopWriting();
 
         closeSocketLock.lock();
         try {
@@ -722,7 +713,7 @@ void handleCommunicationIssue(Exception io) {
             statusLock.unlock();
         }
 
-        writer.preventWrite();
+        writer.stopWriting();
 
         processException(io);
         if (currentServer != null) {

src/main/java/io/nats/client/impl/NatsConnectionWriter.java

@@ -132,7 +132,7 @@ Future<Boolean> stop() {
         return this.stopped;
     }
 
-    void preventWrite() {
+    void stopWriting() {
         allowedToWrite.set(false);
     }