// 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