@ -390,6 +390,10 @@ public class CommandAsyncService implements CommandAsyncExecutor {
}
if (connectionManager.isShuttingDown()) {
return;
if (details.getMainPromise().isCancelled()) {
if (details.getAttemptPromise().cancel(false)) {
AsyncDetails.release(details);
@ -233,6 +233,10 @@ public class CommandBatchService extends CommandReactiveService {
if (mainPromise.isCancelled()) {
attemptPromise.cancel(false);