FP feedback

Author: norareidy

source/fundamentals/crud/read-operations/change-streams.txt

@@ -162,53 +162,55 @@ Split Large Change Events Example
 If your application generates change events that exceed 16 MB in size, the
 server returns a ``BSONObjectTooLarge`` error. To avoid this error, you can use
 the ``$changeStreamSplitLargeEvent`` pipeline stage to split the events
-into smaller fragments.
+into smaller fragments. The {+driver-short+} aggregation API includes the
+``ChangeStreamSplitLargeEvent()`` method, which you can use to add the 
+``$changeStreamSplitLargeEvent`` stage to the change stream pipeline.
 
-After you receive the change stream event fragments, you can use the
-following helper methods to reassemble the fragments into a single
-change stream document: 
+This example instructs the driver to watch for changes and split
+change events that exceed the 16 MB limit. The code prints the
+change document for each event and calls helper methods to
+reassemble any event fragments:
 
 .. tabs::
 
    .. tab:: Asynchronous
-      :tabid: split-event-helpers-async
+      :tabid: change-stream-split-async
 
       .. literalinclude:: /includes/code-examples/change-streams/change-streams.cs
-         :start-after: start-split-event-helpers-async
-         :end-before: end-split-event-helpers-async
+         :start-after: start-split-change-event-async
+         :end-before: end-split-change-event-async
          :language: csharp
 
    .. tab:: Synchronous
-      :tabid: split-event-helpers-sync
+      :tabid: change-stream-split-sync
 
       .. literalinclude:: /includes/code-examples/change-streams/change-streams.cs
-         :start-after: start-split-event-helpers-sync
-         :end-before: end-split-event-helpers-sync
+         :start-after: start-split-change-event-sync
+         :end-before: end-split-change-event-sync
          :language: csharp
 
-This example instructs the driver to watch for changes and split
-change events that exceed the 16 MB limit. The code prints the
-change document for each event and calls the preceding helper methods to
-reassemble any event fragments:
+The preceding example uses the ``GetNextChangeStreamEvent()`` and ``MergeFragment()``
+methods to reassemble change event fragments into a single change stream document.
+The following code defines these methods:
 
 .. tabs::
 
    .. tab:: Asynchronous
-      :tabid: change-stream-split-async
+      :tabid: split-event-helpers-async
 
       .. literalinclude:: /includes/code-examples/change-streams/change-streams.cs
-         :start-after: start-split-change-event-async
-         :end-before: end-split-change-event-async
+         :start-after: start-split-event-helpers-async
+         :end-before: end-split-event-helpers-async
          :language: csharp
 
    .. tab:: Synchronous
-      :tabid: change-stream-split-sync
+      :tabid: split-event-helpers-sync
 
       .. literalinclude:: /includes/code-examples/change-streams/change-streams.cs
-         :start-after: start-split-change-event-sync
-         :end-before: end-split-change-event-sync
+         :start-after: start-split-event-helpers-sync
+         :end-before: end-split-event-helpers-sync
          :language: csharp
-
+         
 .. tip::
 
    To learn more about splitting large change events, see

source/includes/code-examples/change-streams/change-streams.cs

@@ -103,7 +103,7 @@ private static void MergeFragment<TDocument>(
 
 // start-split-event-helpers-async
 // Fetches the next complete change stream event
-private static async Task<ChangeStreamDocument<TDocument>> GetNextChangeStreamEventAsync<TDocument>(
+private static async Task<ChangeStreamDocument<TDocument>> GetNextChangeStreamEvent<TDocument>(
     IAsyncCursor<ChangeStreamDocument<TDocument>> changeStreamCursor)
 {
     var changeStreamEvent = changeStreamCursor.Current.First();
@@ -150,7 +150,7 @@ private static void MergeFragment<TDocument>(
     {
         foreach (var changeStreamEvent in cursor.Current)
         {
-            var completeEvent = await GetNextChangeStreamEventAsync(cursor);
+            var completeEvent = await GetNextChangeStreamEvent(cursor);
             Console.WriteLine("Received the following change: " + completeEvent.BackingDocument);
         }
     }