Make Connection.is_closed() check if protocol's connection state is alive

Author: 1st1

asyncpg/connection.py

@@ -191,7 +191,7 @@ async def set_builtin_type_codec(self, typename, *,
             oid, typename, schema, 'scalar', codec_name)
 
     def is_closed(self):
-        return self._protocol.is_closed() or self._aborted
+        return not self._protocol.is_connected() or self._aborted
 
     async def close(self):
         if self.is_closed():

asyncpg/protocol/protocol.pyx

@@ -240,6 +240,9 @@ cdef class BaseProtocol(CoreProtocol):
     def is_closed(self):
         return self.closing
 
+    def is_connected(self):
+        return not self.closing and self.con_status == CONNECTION_OK
+
     def abort(self):
         if self.closing:
             return