diff --git a/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala b/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala
index a8a2c8ec7f..1a408d07fa 100644
--- a/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala
+++ b/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala
@@ -531,5 +531,6 @@ private[akka] object Running {
       @unused event: PersistentRepr): Unit = ()
   @InternalStableApi
   private[akka] def onWriteSuccess(@unused ctx: ActorContext[_], @unused event: PersistentRepr): Unit = ()
+  @InternalStableApi
   private[akka] def onWriteDone(@unused ctx: ActorContext[_], @unused event: PersistentRepr): Unit = ()
 }
diff --git a/akka-persistence-typed/src/main/scala/akka/persistence/typed/javadsl/RetentionCriteria.scala b/akka-persistence-typed/src/main/scala/akka/persistence/typed/javadsl/RetentionCriteria.scala
index 40e8388255..fee6bdea4d 100644
--- a/akka-persistence-typed/src/main/scala/akka/persistence/typed/javadsl/RetentionCriteria.scala
+++ b/akka-persistence-typed/src/main/scala/akka/persistence/typed/javadsl/RetentionCriteria.scala
@@ -32,6 +32,9 @@ object RetentionCriteria {
    *
    * Use [[SnapshotCountRetentionCriteria.withDeleteEventsOnSnapshot]] to
    * delete old events. Events are not deleted by default.
+   *
+   * If multiple events are persisted with a single Effect, the snapshot will happen after
+   * all of the events are persisted rather than precisely every `numberOfEvents`.
    */
   def snapshotEvery(numberOfEvents: Int, keepNSnapshots: Int): SnapshotCountRetentionCriteria =
     SnapshotCountRetentionCriteriaImpl(numberOfEvents, keepNSnapshots, deleteEventsOnSnapshot = false)
diff --git a/akka-persistence-typed/src/main/scala/akka/persistence/typed/scaladsl/RetentionCriteria.scala b/akka-persistence-typed/src/main/scala/akka/persistence/typed/scaladsl/RetentionCriteria.scala
index 7845618b4f..fd7df34b5c 100644
--- a/akka-persistence-typed/src/main/scala/akka/persistence/typed/scaladsl/RetentionCriteria.scala
+++ b/akka-persistence-typed/src/main/scala/akka/persistence/typed/scaladsl/RetentionCriteria.scala
@@ -32,6 +32,9 @@ object RetentionCriteria {
    *
    * Use [[SnapshotCountRetentionCriteria.withDeleteEventsOnSnapshot]] to
    * delete old events. Events are not deleted by default.
+   *
+   * If multiple events are persisted with a single Effect the snapshot will happen after
+   * all of the events are persisted rather than precisely every `numberOfEvents`.
    */
   def snapshotEvery(numberOfEvents: Int, keepNSnapshots: Int): SnapshotCountRetentionCriteria =
     SnapshotCountRetentionCriteriaImpl(numberOfEvents, keepNSnapshots, deleteEventsOnSnapshot = false)