File tree Expand file tree Collapse file tree 1 file changed +8
-8
lines changed
source/includes/code-examples/change-streams Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -157,21 +157,21 @@ private static void MergeFragment<TDocument>(
157
157
. ChangeStreamSplitLargeEvent ( ) ;
158
158
159
159
using var cursor = collection . Watch ( pipeline ) ;
160
- foreach ( var completeEvent in GetNextChangeStreamEvent ( cursor . ToEnumerable ( ) . GetEnumerator ( ) ) )
161
- {
162
- Console . WriteLine ( "Received the following change: " + completeEvent . BackingDocument ) ;
163
- }
160
+ foreach ( var completeEvent in GetNextChangeStreamEvent ( cursor . ToEnumerable ( ) . GetEnumerator ( ) ) )
161
+ {
162
+ Console . WriteLine ( "Received the following change: " + completeEvent . BackingDocument ) ;
163
+ }
164
164
// end-split-change-event-sync
165
165
166
166
// start-split-change-event-async
167
167
var pipeline = new EmptyPipelineDefinition < ChangeStreamDocument < Restaurant > > ( )
168
168
. ChangeStreamSplitLargeEvent ( ) ;
169
169
170
170
using var cursor = await collection . WatchAsync ( pipeline ) ;
171
- await foreach ( var completeEvent in GetNextChangeStreamEventAsync ( cursor ) )
172
- {
173
- Console . WriteLine ( "Received the following change: " + completeEvent . BackingDocument ) ;
174
- }
171
+ await foreach ( var completeEvent in GetNextChangeStreamEventAsync ( cursor ) )
172
+ {
173
+ Console . WriteLine ( "Received the following change: " + completeEvent . BackingDocument ) ;
174
+ }
175
175
// end-split-change-event-async
176
176
177
177
// start-change-stream-post-image
You can’t perform that action at this time.
0 commit comments