Fix: clear code

Author: Daniil Dumchenko

faststream/kafka/broker/broker.py

@@ -811,7 +811,8 @@ async def publish_batch(
     @override
     async def ping(self, timeout: Optional[float]) -> bool:
         with move_on_after(timeout) as cancel_scope:
-            if cancel_scope.cancel_called:
-                return False
-            else:
-                return not self._producer._producer._closed
+            return not (
+                cancel_scope.cancel_called or
+                self._producer is None or
+                self._producer._producer._closed
+            )

faststream/rabbit/broker/broker.py

@@ -662,6 +662,6 @@ async def ping(self, timeout: Optional[float]) -> bool:
         with move_on_after(timeout) as cancel_scope:
             if cancel_scope.cancel_called:
                 return False
-            if not self._connection or self._connection.is_closed or not self._connection.transport:
+            if not self._connection or self._connection.is_closed:
                 return False
         return True