1515 await foreach ( var message in subscription . Messages ) {
1616 switch ( message ) {
1717 case StreamMessage . Event ( var e ) :
18- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
18+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
1919 semaphore . Release ( ) ;
2020 break ;
2121 case StreamMessage . AllStreamCheckpointReached ( var p ) :
22- Console . WriteLine ( $ "checkpoint taken at { p . PreparePosition } ") ;
22+ // Code to save commit position to a persistent store as a checkpoint
23+ Console . WriteLine ( $ "checkpoint taken at { p . CommitPosition } ") ;
2324 break ;
2425 }
2526 }
@@ -55,7 +56,7 @@ static async Task ExcludeSystemEvents(EventStoreClient client) {
5556 await foreach ( var message in subscription . Messages ) {
5657 switch ( message ) {
5758 case StreamMessage . Event ( var e ) :
58- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
59+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
5960 break ;
6061 }
6162 }
@@ -74,7 +75,7 @@ static async Task EventTypePrefix(EventStoreClient client) {
7475 await foreach ( var message in subscription . Messages ) {
7576 switch ( message ) {
7677 case StreamMessage . Event ( var e ) :
77- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
78+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
7879 break ;
7980 }
8081 }
@@ -91,7 +92,7 @@ static async Task EventTypeRegex(EventStoreClient client) {
9192 await foreach ( var message in subscription . Messages ) {
9293 switch ( message ) {
9394 case StreamMessage . Event ( var e ) :
94- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
95+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
9596 break ;
9697 }
9798 }
@@ -108,7 +109,7 @@ static async Task StreamPrefix(EventStoreClient client) {
108109 await foreach ( var message in subscription . Messages ) {
109110 switch ( message ) {
110111 case StreamMessage . Event ( var e ) :
111- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
112+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
112113 break ;
113114 }
114115 }
@@ -125,7 +126,7 @@ static async Task StreamRegex(EventStoreClient client) {
125126 await foreach ( var message in subscription . Messages ) {
126127 switch ( message ) {
127128 case StreamMessage . Event ( var e ) :
128- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
129+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
129130 break ;
130131 }
131132 }
@@ -140,10 +141,11 @@ static async Task CheckpointCallback(EventStoreClient client) {
140141 await foreach ( var message in subscription . Messages ) {
141142 switch ( message ) {
142143 case StreamMessage . Event ( var e ) :
143- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
144+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
144145 break ;
145146 case StreamMessage . AllStreamCheckpointReached ( var p ) :
146- Console . WriteLine ( $ "checkpoint taken at { p . PreparePosition } ") ;
147+ // Save commit position to a persistent store as a checkpoint
148+ Console . WriteLine ( $ "checkpoint taken at { p . CommitPosition } ") ;
147149 break ;
148150 }
149151 }
@@ -162,10 +164,11 @@ static async Task CheckpointCallbackWithInterval(EventStoreClient client) {
162164 await foreach ( var message in subscription . Messages ) {
163165 switch ( message ) {
164166 case StreamMessage . Event ( var e ) :
165- Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . PreparePosition } ") ;
167+ Console . WriteLine ( $ "{ e . Event . EventType } @ { e . Event . Position . CommitPosition } ") ;
166168 break ;
167169 case StreamMessage . AllStreamCheckpointReached ( var p ) :
168- Console . WriteLine ( $ "checkpoint taken at { p . PreparePosition } ") ;
170+ // Save commit position to a persistent store as a checkpoint
171+ Console . WriteLine ( $ "checkpoint taken at { p . CommitPosition } ") ;
169172 break ;
170173 }
171174 }
0 commit comments