From 491afd454b81efdf292f62fdbbac76a3363aa4c5 Mon Sep 17 00:00:00 2001 From: Stepan Usatiuk Date: Sun, 13 Apr 2025 12:08:40 +0200 Subject: [PATCH] Objects: serialize written objects in parallel --- .../objects/stores/SerializingObjectPersistentStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dhfs-parent/objects/src/main/java/com/usatiuk/objects/stores/SerializingObjectPersistentStore.java b/dhfs-parent/objects/src/main/java/com/usatiuk/objects/stores/SerializingObjectPersistentStore.java index fdc1b4e0..5859d503 100644 --- a/dhfs-parent/objects/src/main/java/com/usatiuk/objects/stores/SerializingObjectPersistentStore.java +++ b/dhfs-parent/objects/src/main/java/com/usatiuk/objects/stores/SerializingObjectPersistentStore.java @@ -59,7 +59,7 @@ public class SerializingObjectPersistentStore { private TxManifestRaw prepareManifest(TxManifestObj objs) { return new TxManifestRaw( - objs.written().stream() + objs.written().parallelStream() .map(e -> Pair.of(e.getKey(), serializer.serialize(e.getValue()))) .toList() , objs.deleted());