Skip to content

Commit f8615ad

Browse files
committed
improve ChangeStream cursor test to assert cursor id is unchanged
1 parent cfaaba6 commit f8615ad

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

test-common/src/main/java/de/bwaldvogel/mongo/backend/AbstractOplogTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -243,13 +243,20 @@ public void testChangeStreamInsertAndUpdateFullDocumentLookup() {
243243
try (MongoChangeStreamCursor<ChangeStreamDocument<Document>> cursor =
244244
collection.watch(pipeline).fullDocument(FullDocument.UPDATE_LOOKUP).cursor()) {
245245

246+
final long cursorId = cursor.getServerCursor().getId();
247+
246248
for (int i = 1; i < numberOfDocs + 1; i++) {
247249
Document doc = json(String.format("a: %d, b: 1", i));
248250
collection.insertOne(doc);
249251
collection.updateOne(eq("a", i), set("c", i * 10));
250252

253+
assertThat(cursor.hasNext()).isTrue();
251254
ChangeStreamDocument<Document> insertDocument = cursor.next();
255+
assertThat(cursor.getServerCursor().getId()).isEqualTo(cursorId);
256+
257+
assertThat(cursor.hasNext()).isTrue();
252258
ChangeStreamDocument<Document> updateDocument = cursor.next();
259+
assertThat(cursor.getServerCursor().getId()).isEqualTo(cursorId);
253260

254261
assertThat(insertDocument.getFullDocument().get("a")).isEqualTo(i);
255262
insert.add(insertDocument.getFullDocument());

0 commit comments

Comments
 (0)