+
+ private void persistCallback(final ReplicatedLogEntry persistedLogEntry,
+ final Consumer<ReplicatedLogEntry> callback) {
+ context.getExecutor().execute(() -> syncPersistCallback(persistedLogEntry, callback));
+ }
+
+ private void syncPersistCallback(final ReplicatedLogEntry persistedLogEntry,
+ final Consumer<ReplicatedLogEntry> callback) {
+ context.getLogger().debug("{}: persist complete {}", context.getId(), persistedLogEntry);
+
+ dataSizeSinceLastSnapshot += persistedLogEntry.size();
+
+ if (callback != null) {
+ callback.accept(persistedLogEntry);
+ }
+ }