Fix EOF processing while client is connecting (#775)

Signed-off-by: Ksenia Vazhdaeva <[email protected]>
Co-authored-by: Ksenia Vazhdaeva <[email protected]>
Co-authored-by: Waldemar Quevedo <[email protected]>

Author: 3 people

nats/src/nats/aio/client.py

@@ -1406,10 +1406,10 @@ async def _process_op_err(self, e: Exception) -> None:
         try to switch the server to which it is currently connected
         otherwise it will disconnect.
         """
-        if self.is_connecting or self.is_closed or self.is_reconnecting:
+        if self.is_closed or self.is_reconnecting:
             return
 
-        if self.options["allow_reconnect"] and self.is_connected:
+        if self.options["allow_reconnect"] and (self.is_connected or self.is_connecting):
             self._status = Client.RECONNECTING
             self._ps.reset()
 
@@ -2073,7 +2073,7 @@ async def _read_loop(self) -> None:
                 should_bail = self.is_closed or self.is_reconnecting
                 if should_bail or self._transport is None:
                     break
-                if self.is_connected and self._transport.at_eof():
+                if self._transport.at_eof():
                     err = errors.UnexpectedEOF()
                     await self._error_cb(err)
                     await self._process_op_err(err)