File tree 1 file changed +1
-2
lines changed
source/includes/code-examples/change-streams
1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -70,7 +70,6 @@ await cursor.ForEachAsync(change =>
70
70
private static ChangeStreamDocument < TDocument > GetNextChangeStreamEvent < TDocument > (
71
71
IEnumerator < ChangeStreamDocument < TDocument > > changeStreamEnumerator )
72
72
{
73
- changeStreamEnumerator . MoveNext ( ) ;
74
73
var changeStreamEvent = changeStreamEnumerator . Current ;
75
74
76
75
// Reassembles change event fragments if the event is split
@@ -169,7 +168,7 @@ private static void MergeFragment<TDocument>(
169
168
while ( enumerator . MoveNext ( ) )
170
169
{
171
170
var completeEvent = GetNextChangeStreamEvent ( enumerator ) ;
172
- Console . WriteLine ( "Reassembled change event : " + completeEvent . FullDocument ) ;
171
+ Console . WriteLine ( "Received the following change : " + completeEvent . BackingDocument ) ;
173
172
}
174
173
}
175
174
}
You can’t perform that action at this time.
0 commit comments