Skip to content

Commit 442f519

Browse files
committed
Fix broken unit test
1 parent 9ca34f0 commit 442f519

File tree

2 files changed

+24
-2
lines changed

2 files changed

+24
-2
lines changed

dotnet/src/Connectors/Connectors.CosmosNoSql.UnitTests/CosmosNoSqlCollectionTests.cs

+22
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,28 @@ public async Task EnsureCollectionExistsUsesValidContainerPropertiesAsync(Indexi
137137
// Arrange
138138
const string CollectionName = "collection";
139139

140+
var mockFeedResponse = new Mock<FeedResponse<string>>();
141+
mockFeedResponse
142+
.Setup(l => l.Resource)
143+
.Returns([]);
144+
145+
var mockFeedIterator = new Mock<FeedIterator<string>>();
146+
mockFeedIterator
147+
.SetupSequence(l => l.HasMoreResults)
148+
.Returns(true)
149+
.Returns(false);
150+
151+
mockFeedIterator
152+
.Setup(l => l.ReadNextAsync(It.IsAny<CancellationToken>()))
153+
.ReturnsAsync(mockFeedResponse.Object);
154+
155+
this._mockDatabase
156+
.Setup(l => l.GetContainerQueryIterator<string>(
157+
It.IsAny<QueryDefinition>(),
158+
It.IsAny<string>(),
159+
It.IsAny<QueryRequestOptions>()))
160+
.Returns(mockFeedIterator.Object);
161+
140162
var sut = new CosmosNoSqlCollection<string, TestIndexingModel>(
141163
this._mockDatabase.Object,
142164
CollectionName,

dotnet/src/Connectors/Connectors.Memory.CosmosNoSql/CosmosNoSqlCollection.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -151,9 +151,9 @@ public override async Task<bool> CollectionExistsAsync(CancellationToken cancell
151151

152152
using var errorHandlingFeedIterator = new ErrorHandlingFeedIterator<string>(feedIterator, this._collectionMetadata, OperationName);
153153

154-
while (feedIterator.HasMoreResults)
154+
while (errorHandlingFeedIterator.HasMoreResults)
155155
{
156-
var next = await feedIterator.ReadNextAsync(cancellationToken).ConfigureAwait(false);
156+
var next = await errorHandlingFeedIterator.ReadNextAsync(cancellationToken).ConfigureAwait(false);
157157

158158
foreach (var containerName in next.Resource)
159159
{

0 commit comments

Comments
 (0)