diff --git a/Milvus.Client/MilvusCollection.Entity.cs b/Milvus.Client/MilvusCollection.Entity.cs index 3bc7f41..7cd8bb3 100644 --- a/Milvus.Client/MilvusCollection.Entity.cs +++ b/Milvus.Client/MilvusCollection.Entity.cs @@ -534,7 +534,7 @@ public async IAsyncEnumerable> QueryWithIteratorAsync( var leftItemsCount = userLimit - processedItemsCount; // If user limit is reached, we should break the loop - if(leftItemsCount == 0) yield break; + if(leftItemsCount <= 0) yield break; // Setup next iteration limit and expression ReplaceKeyValueItems(