// Start Changestream Example 1

MongoCursor<Document> cursor = inventory.watch().iterator();
Document next = cursor.next();

// End Changestream Example 1

// Start Changestream Example 2

MongoCursor<Document> cursor = 
inventory.watch().fullDocument(FullDocument.UPDATE_LOOKUP).iterator();
Document next = cursor.next();

// End Changestream Example 2

// Start Changestream Example 3

Document resumeToken = next.get("_id", Document.class);
MongoCursor<Document> cursor = inventory.watch().resumeAfter(resumeToken).iterator();
cursor.next();

// End Changestream Example 3

// Start Changestream Example 4

List<Bson> pipeline = singletonList(Aggregates.match(Filters.or(
   Document.parse("{'fullDocument.username': 'alice'}"),
   Filters.in("operationType", asList("delete")))));

// End Changestream Example 4