diff --git a/src/io_threads.c b/src/io_threads.c
index 1930600ff16..9050eab0575 100644
--- a/src/io_threads.c
+++ b/src/io_threads.c
@@ -870,7 +870,8 @@ static void handleReadJobs(client **read_jobs, int read_count) {
             client *c = lookupClientByID(read_client_ids[i]);
             if (!c || !c->conn) continue;
 
-            if (processPendingCommandAndInputBuffer(c) == C_OK) beforeNextClient(c);
+            if (processPendingCommandAndInputBuffer(c) == C_ERR) continue;
+            beforeNextClient(c);
 
             c = lookupClientByID(read_client_ids[i]);
             if (!c || !c->conn) continue;