@@ -352,13 +352,13 @@
 			default:
 				assert(0);
 			}
 		}
 
-		[queue removeNObjects: count];
-		[queueInfo removeNItems: count];
-		[queueFDs removeNItems: count];
+		[queue removeAllObjects];
+		[queueInfo removeAllItems];
+		[queueFDs removeAllItems];
 	} @finally {
 		[mutex unlock];
 	}
 }