updated docs to reflect eventually consistent append listener api change - returning lastseen ref now

Author: vanrogu

_posts/2025-11-09-eventstore-quickstart.md

@@ -388,6 +388,7 @@ stream.subscribe(new EventStreamEventuallyConsistentAppendListener() {
         if (!newEvents.isEmpty()) {
             lastSeen.set(newEvents.getLast().reference());
         }
+        return lastSeen.get();
     }
 });
 ```

_posts/2025-11-29-eventstore-bookmarking.md

@@ -119,6 +119,7 @@ stream.subscribe((EventReference atLeastUntil) -> {
                 Tags.of("processed-at", Instant.now().toString())
             );
         });
+    return null;
 });
 
 // Initial catch-up: process all existing events

_posts/2025-11-29-eventstore-listeners.md

@@ -54,12 +54,12 @@ stream.subscribe((EventReference atLeastUntil) -> {
     stream.query(EventQuery.matchAll(), lastProcessed.get())
         .forEach(event -> {
             System.out.println("Processing: " + event.type());
-            updateReadModel(event);
+            lastProcessed.set(event.reference());
         });
 
     // Update bookmark for resumability
-    lastProcessed.set(atLeastUntil);
     stream.placeBookmark("order-processor", atLeastUntil, Tags.none());
+    return lastProcessed.get();
 });
 ```
 

_posts/2025-11-29-eventstore-projecting-events.md

@@ -419,7 +419,7 @@ public class CustomerProjectionService {
 	/*
 	 *  This method is called asynchronously each time the 
 	 */	
-    private void updateProjection(EventReference atLeastUntil) {
+    private EventReference updateProjection(EventReference atLeastUntil) {
 
         // Project new events, bookmark is fetched before this run (ref builder instructions above)
         ProjectorMetrics metrics = projector.run();
@@ -430,6 +430,8 @@ public class CustomerProjectionService {
         }
 
         // Bookmark is automatically updated after each run
+        
+        return metrics.lastEventReference();
     }
 
     public CustomerSummary getProjection() {