DOCSP-39702 Standardize change streams page (#69)

Author: jordan-smith721

source/includes/read/change-streams.java

@@ -0,0 +1,36 @@
+// start-open-change-stream
+// Opens a change stream and prints the changes as they're received
+ChangeStreamPublisher<Document> changeStreamPublisher = restaurants.watch();
+Flux.from(changeStreamPublisher)
+        .doOnNext(change -> System.out.println("Received change: " + change))
+        .blockLast();
+// end-open-change-stream
+
+// start-change-stream-pipeline
+// Creates a change stream pipeline
+List<Bson> pipeline = Arrays.asList(
+        Aggregates.match(Filters.eq("operationType", "update"))
+);
+
+// Opens a change stream and prints the changes as they're received
+ChangeStreamPublisher<Document> changeStreamPublisher = restaurants.watch(pipeline);
+Flux.from(changeStreamPublisher)
+        .doOnNext(change -> System.out.println("Received change: " + change))
+        .blockLast();
+// end-change-stream-pipeline
+
+// start-change-stream-post-image
+// Creates a change stream pipeline
+List<Bson> pipeline = Arrays.asList(
+        Aggregates.match(Filters.eq("operationType", "update"))
+);
+
+// Opens a change stream and prints the changes as they're received including the full
+// document after the update
+ChangeStreamPublisher<Document> changeStreamPublisher = restaurants.watch(pipeline)
+        .fullDocument(FullDocument.UPDATE_LOOKUP);
+
+Flux.from(changeStreamPublisher)
+        .doOnNext(change -> System.out.println("Received change: " + change))
+        .blockLast();
+// end-change-stream-post-image

source/read-data-from-mongo.txt

@@ -31,7 +31,7 @@ Read Data From MongoDB
     /read/read-preference
     /read/text-search
     /read/geo
-    /read/change-stream
+    /read/change-streams
 
 Overview
 --------
@@ -181,4 +181,4 @@ subsequent change events in that collection:
    :language: java
    :copyable:
 
-To learn more about the ``watch()`` method, see the :ref:`Monitor Data Changes <java-rs-monitor-changes>` guide.
+To learn more about the ``watch()`` method, see the :ref:`Monitor Data Changes <java-rs-change-streams>` guide.