@@ -67,25 +67,25 @@ await cursor.ForEachAsync(change =>
6767
6868// start-split-event-helpers-sync
6969// Fetches the next complete change stream event
70- private static IEnumerable < ChangeStreamDocument < TDocument > > GetNextChangeStreamEvent < TDocument > (
71- IEnumerator < ChangeStreamDocument < TDocument > > changeStreamEnumerator )
72- {
73- while ( changeStreamEnumerator . MoveNext ( ) )
74- {
75- var changeStreamEvent = changeStreamEnumerator . Current ;
76- if ( changeStreamEvent . SplitEvent != null )
77- {
78- var fragment = changeStreamEvent ;
79- while ( fragment . SplitEvent . Fragment < fragment . SplitEvent . Of )
80- {
81- changeStreamEnumerator . MoveNext ( ) ;
82- fragment = changeStreamEnumerator . Current ;
83- MergeFragment ( changeStreamEvent , fragment ) ;
84- }
85- }
86- yield return changeStreamEvent ;
87- }
88- }
70+ private static IEnumerable < ChangeStreamDocument < TDocument > > GetNextChangeStreamEvent < TDocument > (
71+ IEnumerator < ChangeStreamDocument < TDocument > > changeStreamEnumerator )
72+ {
73+ while ( changeStreamEnumerator . MoveNext ( ) )
74+ {
75+ var changeStreamEvent = changeStreamEnumerator . Current ;
76+ if ( changeStreamEvent . SplitEvent != null )
77+ {
78+ var fragment = changeStreamEvent ;
79+ while ( fragment . SplitEvent . Fragment < fragment . SplitEvent . Of )
80+ {
81+ changeStreamEnumerator . MoveNext ( ) ;
82+ fragment = changeStreamEnumerator . Current ;
83+ MergeFragment ( changeStreamEvent , fragment ) ;
84+ }
85+ }
86+ yield return changeStreamEvent ;
87+ }
88+ }
8989
9090// Merges a fragment into the base event
9191private static void MergeFragment < TDocument > (
0 commit comments