avoid to call the

DeleteEntityFromTheServer when the socket is closed

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.Stream.Client/AbstractEntity.cs

@@ -93,12 +93,10 @@ protected async Task<ResponseCode> Shutdown(EntityCommonConfig config, bool igno
             }
 
             UpdateStatusToClosed();
-            if (_client is { IsClosed: true })
-            {
-                return ResponseCode.Ok;
-            }
-
-            var result = await DeleteEntityFromTheServer(ignoreIfAlreadyDeleted).ConfigureAwait(false);
+            
+            // we can ignore if the ignoreIfAlreadyDeleted or the socket is already closed
+            var ignore = ignoreIfAlreadyDeleted || _client.IsClosed;
+            var result = await DeleteEntityFromTheServer(ignore).ConfigureAwait(false);
 
             var closed = await _client.MaybeClose($"closing: {EntityId}", config.Pool)
                 .ConfigureAwait(false);