Skip to content
Merged
Prev Previous commit
Update driver-sync/src/test/unit/com/mongodb/client/internal/ChangeSt…
…reamIterableSpecification.groovy
  • Loading branch information
rozza authored Aug 26, 2025
commit 0ba9db272cc86f1697e9f44d7a32b1ceba9aedad
Original file line number Diff line number Diff line change
Expand Up @@ -208,8 +208,9 @@ class ChangeStreamIterableSpecification extends Specification {
given:
def count = 0
def cannedResults = ['{_id: { _data: 1}}', '{_id: {_data: 2}}', '{_id: {_data: 3}}'].collect { RawBsonDocument.parse(it) }
def executor = new TestOperationExecutor([cursor(cannedResults.collect()), cursor(cannedResults.collect()), cursor(cannedResults.collect()),
cursor(cannedResults.collect()), cursor(cannedResults.collect())])
def executor = new TestOperationExecutor([cursor(cannedResults.collect()), cursor(cannedResults.collect()),
cursor(cannedResults.collect()), cursor(cannedResults.collect()),
cursor(cannedResults.collect())])
def mongoIterable = new ChangeStreamIterableImpl(null, namespace, codecRegistry, readPreference, readConcern, executor, [],
Document, ChangeStreamLevel.COLLECTION, true, TIMEOUT_SETTINGS).withDocumentClass(RawBsonDocument)

Expand Down