Skip to content

Commit 035548f

Browse files
author
Oleksandr Poliakov
committed
PR
1 parent 0eb0700 commit 035548f

File tree

2 files changed

+4
-53
lines changed

2 files changed

+4
-53
lines changed

tests/MongoDB.Driver.TestHelpers/OnlyOnceEnumerable.cs

Lines changed: 0 additions & 51 deletions
This file was deleted.

tests/MongoDB.Driver.Tests/MongoCollectionImplTests.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -464,10 +464,12 @@ public async Task BulkWrite_should_enumerate_requests_once([Values(false, true)]
464464
processedRequests: new[] { processedRequest },
465465
upserts: new List<BulkWriteOperationUpsert>());
466466
_operationExecutor.EnqueueResult<BulkWriteOperationResult>(operationResult);
467-
var wrappedRequests = OnlyOnceEnumerable.Create(requests);
467+
var wrappedRequests = new Mock<IEnumerable<WriteModel<BsonDocument>>>();
468+
wrappedRequests.Setup(e => e.GetEnumerator()).Returns(((IEnumerable<WriteModel<BsonDocument>>)requests).GetEnumerator());
468469

469-
var result = async ? await subject.BulkWriteAsync(wrappedRequests) : subject.BulkWrite(wrappedRequests);
470+
var result = async ? await subject.BulkWriteAsync(wrappedRequests.Object) : subject.BulkWrite(wrappedRequests.Object);
470471

472+
wrappedRequests.Verify(e => e.GetEnumerator(), Times.Once);
471473
result.Should().NotBeNull();
472474
result.RequestCount.Should().Be(1);
473475
result.ProcessedRequests.ShouldBeEquivalentTo(requests);

0 commit comments

Comments
 (0)