停止使用 Java 驱动程序查看 MongoDB 更改流

Question

MongoDB Java 驱动程序清楚地解释了如何观察一个集合并启动/打开一个更改流，这是一个 ChangeStreamIterable：

http://mongodb.github.io/mongo-java-driver/3.9/driver/tutorials/change-streams/

MongoClient mongoClient = MongoClients.create(new ConnectionString("mongodb://localhost:27017,localhost:27018,localhost:27019"));
MongoDatabase database = mongoClient.getDatabase("test");
MongoCollection<Document> collection = database.getCollection("restaurants");

collection.watch().forEach(printBlock);

但是没有关于关闭更改流的解释，API似乎也不支持关闭操作。

为什么不可能？这不是必要的，还是只是疏忽？

适用于所有版本的标准、异步和响应式驱动程序。

Answer 1

您可以从 ChangeStreamIterable 中获得一个可关闭的光标。

MongoCursor<ChangeStreamDocument<Document>> cursor = collection.watch().iterator();
cursor.close();